kinesis-consumer/store/redis/options.go
2024-09-13 14:14:56 +02:00

13 lines
314 B
Go

package redis
import "github.com/redis/go-redis/v9"
// Option is used to override defaults when creating a new Redis checkpoint
type Option func(*Checkpoint)
// WithClient overrides the default client
func WithClient(client redis.UniversalClient) Option {
return func(c *Checkpoint) {
c.client = client
}
}