rdb

Documentation

Index

• func GetUniversalClient(ctx context.Context, c ...di.Container) (redis.UniversalClient, error)
• func MakerActivator() *di.Activator
• func New(cfg *Config) redis.UniversalClient
• func NewUniversalClient(ctx context.Context, c ...di.Container) (redis.UniversalClient, error)
• func UniversalClientActivator(configKey string) *di.Activator
• type Config
  • func (cfg *Config) Init()
• type MakerKey
• type UniversalClientKey
• type UniversalClientMaker
  • func GetMaker(ctx context.Context, c ...di.Container) (*UniversalClientMaker, error)
  • func (m *UniversalClientMaker) Make() redis.UniversalClient
  • func (m *UniversalClientMaker) MakeRedisClient() any

Functions

func GetUniversalClient

func GetUniversalClient(ctx context.Context, c ...di.Container) (redis.UniversalClient, error)

func MakerActivator

func MakerActivator() *di.Activator

func New

func New(cfg *Config) redis.UniversalClient

func NewUniversalClient

func NewUniversalClient(ctx context.Context, c ...di.Container) (redis.UniversalClient, error)

func UniversalClientActivator

func UniversalClientActivator(configKey string) *di.Activator

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"`
	Ping             bool          `mapstructure:"ping"`
}

func (*Config) Init

func (cfg *Config) Init()

type MakerKey

type MakerKey struct{}

type UniversalClientKey

type UniversalClientKey struct{}

type UniversalClientMaker

type UniversalClientMaker struct {
	// contains filtered or unexported fields
}

func GetMaker

func GetMaker(ctx context.Context, c ...di.Container) (*UniversalClientMaker, error)

func (*UniversalClientMaker) Make

func (m *UniversalClientMaker) Make() redis.UniversalClient

func (*UniversalClientMaker) MakeRedisClient

func (m *UniversalClientMaker) MakeRedisClient() any