rdb

package
v2.0.0-beta2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 5, 2023 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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"`
	ClientName            string        `mapstructure:"client_name"`
	DB                    int           `mapstructure:"db"`
	Username              string        `mapstructure:"username"`
	Password              string        `mapstructure:"password"`
	SentinelUsername      string        `mapstructure:"sentinel_username"`
	SentinelPassword      string        `mapstructure:"sentinel_password"`
	MaxRetries            int           `mapstructure:"max_retries"`
	MinRetryBackoff       time.Duration `mapstructure:"min_retry_backoff"`
	MaxRetryBackoff       time.Duration `mapstructure:"max_retry_backoff"`
	DialTimeout           time.Duration `mapstructure:"dial_timeout"`
	ReadTimeout           time.Duration `mapstructure:"read_timeout"`
	WriteTimeout          time.Duration `mapstructure:"write_timeout"`
	ContextTimeoutEnabled bool          `mapstructure:"context_timeout_enabled"`
	PoolFIFO              bool          `mapstructure:"pool_fifo"`
	PoolSize              int           `mapstructure:"pool_size"`
	PoolTimeout           time.Duration `mapstructure:"pool_timeout"`
	MinIdleConns          int           `mapstructure:"min_idle_conns"`
	MaxIdleConns          int           `mapstructure:"max_idle_conns"`
	ConnMaxIdleTime       time.Duration `mapstructure:"conn_max_idle_time"`
	ConnMaxLifetime       time.Duration `mapstructure:"conn_max_life_time"`
	MaxRedirects          int           `mapstructure:"max_redirects"`
	ReadOnly              bool          `mapstructure:"read_only"`
	RouteByLatency        bool          `mapstructure:"route_by_latency"`
	RouteRandomly         bool          `mapstructure:"route_randomly"`
	MasterName            string        `mapstructure:"master_name"`
	Ping                  bool          `mapstructure:"ping"`
}

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 (*UniversalClientMaker) MakeRedisClient

func (m *UniversalClientMaker) MakeRedisClient() any

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL