redisc

Documentation

Index

• Constants
• Variables
• func DefaultCfg() *redis.Options
• type Cfg
• type Client
  • func (t *Client) Get(ctx context.Context, options ...func(*redis.Options)) *redis.Client
  • func (t *Client) Kind() string
  • func (t *Client) UpdateResObj(val interface{})

Constants

const (
	DbType                  = "redis"
	SpanKind                = ext.SpanKindEnum("redis-client")
	MaxPipelineNameCmdCount = 3
	DefaultRWTimeout        = time.Second
)

Variables

var Name = "redis"

Functions

func DefaultCfg

func DefaultCfg() *redis.Options

Types

type Cfg

type Cfg struct {
	Network            string        `json:"network" yaml:"network"`
	Addr               string        `json:"addr" yaml:"addr"`
	Username           string        `json:"username" yaml:"username"`
	Password           string        `json:"password" yaml:"password"`
	DB                 int           `json:"db" yaml:"db"`
	MaxRetries         int           `json:"max_retries" yaml:"max_retries"`
	MinRetryBackoff    time.Duration `json:"min_retry_backoff" yaml:"min_retry_backoff"`
	MaxRetryBackoff    time.Duration `json:"max_retry_backoff" yaml:"max_retry_backoff"`
	DialTimeout        time.Duration `json:"dial_timeout" yaml:"dial_timeout"`
	ReadTimeout        time.Duration `json:"read_timeout" yaml:"read_timeout"`
	WriteTimeout       time.Duration `json:"write_timeout" yaml:"write_timeout"`
	PoolSize           int           `json:"pool_size" yaml:"pool_size"`
	MinIdleConns       int           `json:"min_idle_conns" yaml:"min_idle_conns"`
	MaxConnAge         time.Duration `json:"max_conn_age" yaml:"max_conn_age"`
	PoolTimeout        time.Duration `json:"pool_timeout" yaml:"pool_timeout"`
	IdleTimeout        time.Duration `json:"idle_timeout" yaml:"idle_timeout"`
	IdleCheckFrequency time.Duration `json:"idle_check_frequency" yaml:"idle_check_frequency"`
}

type Client

type Client struct {
	*redis.Client
}

func (*Client) Get

func (t *Client) Get(ctx context.Context, options ...func(*redis.Options)) *redis.Client

func (*Client) Kind

func (t *Client) Kind() string

func (*Client) UpdateResObj

func (t *Client) UpdateResObj(val interface{})