Documentation ¶
Index ¶
- Constants
- func NewRedisDriver(log logger.Logger, key string, cfgPlugin config.Configurer) (kv.Storage, error)
- type Config
- type Driver
- func (d *Driver) Delete(keys ...string) error
- func (d *Driver) Get(key string) ([]byte, error)
- func (d *Driver) Has(keys ...string) (map[string]bool, error)
- func (d *Driver) MExpire(items ...*kvv1.Item) error
- func (d *Driver) MGet(keys ...string) (map[string][]byte, error)
- func (d *Driver) Set(items ...*kvv1.Item) error
- func (d *Driver) TTL(keys ...string) (map[string]string, error)
- type Plugin
Constants ¶
View Source
const PluginName = "redis"
Variables ¶
This section is empty.
Functions ¶
func NewRedisDriver ¶
Types ¶
type Config ¶
type Config struct { Addrs []string `mapstructure:"addrs"` DB int `mapstructure:"db"` Username string `mapstructure:"username"` Password string `mapstructure:"password"` MasterName string `mapstructure:"master_name"` SentinelPassword string `mapstructure:"sentinel_password"` RouteByLatency bool `mapstructure:"route_by_latency"` RouteRandomly bool `mapstructure:"route_randomly"` MaxRetries int `mapstructure:"max_retries"` DialTimeout time.Duration `mapstructure:"dial_timeout"` MinRetryBackoff time.Duration `mapstructure:"min_retry_backoff"` MaxRetryBackoff time.Duration `mapstructure:"max_retry_backoff"` PoolSize int `mapstructure:"pool_size"` MinIdleConns int `mapstructure:"min_idle_conns"` MaxConnAge time.Duration `mapstructure:"max_conn_age"` ReadTimeout time.Duration `mapstructure:"read_timeout"` WriteTimeout time.Duration `mapstructure:"write_timeout"` PoolTimeout time.Duration `mapstructure:"pool_timeout"` IdleTimeout time.Duration `mapstructure:"idle_timeout"` IdleCheckFreq time.Duration `mapstructure:"idle_check_freq"` ReadOnly bool `mapstructure:"read_only"` }
func (*Config) InitDefaults ¶
func (s *Config) InitDefaults()
InitDefaults initializing fill config with default values
type Driver ¶
type Driver struct {
// contains filtered or unexported fields
}
func (*Driver) MExpire ¶
MExpire https://redis.io/commands/expire timeout in RFC3339
func (*Driver) MGet ¶
MGet loads content of multiple values (some values might be skipped). https://redis.io/commands/mget Returns slice with the interfaces with values
func (*Driver) Set ¶
Set sets value with the TTL in seconds https://redis.io/commands/set Redis `SET key value [expiration]` command.
Use expiration for `SETEX`-like behavior. Zero expiration means the key has no expiration time.
Click to show internal directories.
Click to hide internal directories.