redis

Dec 17, 2024

Changes in this version

type Client

+ func (c *Client) MarshalLogObject(encoder zapcore.ObjectEncoder) error

type Config

+ Database int

+ Username string

May 24, 2024

Changes in this version

+ var NewScript = redis.NewScript

+ func WrapCmdErr(cmd redis.Cmder) error

+ type Client struct

+ Options *Options

+ func NewClient(client *redis.Client, logger *logging.Logger, options *Options) *Client

+ func NewClientFromConfig(c *Config, logger *logging.Logger) (*Client, error)

+ func (c *Client) GetAddr() string

+ func (c *Client) HMYield(ctx context.Context, key string, fields ...string) (<-chan HPair, <-chan error)

+ func (c *Client) HYield(ctx context.Context, key string) (<-chan HPair, <-chan error)

+ func (c *Client) XReadUntilResult(ctx context.Context, a *redis.XReadArgs) ([]redis.XStream, error)

+ type Config struct

+ Host string

+ Options Options

+ Password string

+ Port int

+ TlsOptions config.TLS

+ func (r *Config) Validate() error

+ type HPair struct

+ Field string

+ Value string

+ type IntCmd = redis.IntCmd

+ type Options struct

+ BlockTimeout time.Duration

+ HMGetCount int

+ HScanCount int

+ MaxHMGetConnections int

+ Timeout time.Duration

+ XReadCount int

+ func (o *Options) Validate() error

+ type Pipeliner = redis.Pipeliner

+ type Streams map[string]string

+ func (s Streams) Option() []string

+ type XAddArgs = redis.XAddArgs

+ type XMessage = redis.XMessage

+ type XReadArgs = redis.XReadArgs