kinesis-consumer/store/redis/options.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
	}
}