Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WrapCmdErr ¶
func WrapCmdErr(cmd redis.Cmder) error
WrapCmdErr adds the command itself and the stack of the current goroutine to the command's error if any.
Types ¶
type Client ¶
type Client struct {
*redis.Client
Options *Options
// contains filtered or unexported fields
}
Client is a wrapper around redis.Client with streaming and logging capabilities.
func NewClientFromConfig ¶
NewClientFromConfig returns a new Client from Config.
func (*Client) HMYield ¶
func (c *Client) HMYield(ctx context.Context, key string, fields ...string) (<-chan HPair, <-chan error)
HMYield yields HPair field-value pairs for the specified fields in the hash stored at key.
func (*Client) HYield ¶
HYield yields HPair field-value pairs for all fields in the hash stored at key.
func (*Client) XReadUntilResult ¶
XReadUntilResult (repeatedly) calls XREAD with the specified arguments until a result is returned. Each call blocks at most for the duration specified in Options.BlockTimeout until data is available before it times out and the next call is made. This also means that an already set block timeout is overridden.
type Config ¶
type Config struct {
Host string `yaml:"host"`
Port int `yaml:"port"`
Database int `yaml:"database" default:"0"`
Password string `yaml:"password"`
TlsOptions config.TLS `yaml:",inline"`
Options Options `yaml:"options"`
}
Config defines Config client configuration.
type Options ¶
type Options struct {
BlockTimeout time.Duration `yaml:"block_timeout" default:"1s"`
HMGetCount int `yaml:"hmget_count" default:"4096"`
HScanCount int `yaml:"hscan_count" default:"4096"`
MaxHMGetConnections int `yaml:"max_hmget_connections" default:"8"`
MinPoolSize int `yaml:"min_pool_size" default:"32"`
Timeout time.Duration `yaml:"timeout" default:"30s"`
XReadCount int `yaml:"xread_count" default:"4096"`
}
Options define user configurable Redis options.
Source Files