goredisinjectors

Documentation

Index

• func InitRedisClient(options ...option.Option) redis.UniversalClient
• func InitRedisClusterClient(options ...option.Option) redis.UniversalClient
• func WithGoRedisClusterOpts(opts *redis.ClusterOptions) option.Option
• func WithGoRedisOpts(opts *redis.Options) option.Option
• func WithLimiter(limiter redis.Limiter) option.Option
• func WithRedisAddr(addr string) option.Option
• func WithRedisClientCommonOptions(opts RedisClientCommonOptions) option.Option
• func WithRedisClusterAddrs(addrs []string) option.Option
• func WithRedisClusterRoute(route string) option.Option
• func WithRedisDB(db int) option.Option
• type RedisClientCommonOptions
  • func DefaultRedisClientCommonOptions() *RedisClientCommonOptions
• type RedisClientOptions
  • func DefaultRedisClientOptions() *RedisClientOptions
  • func (m *RedisClientOptions) String() string
• type RedisClusterClientOptions
  • func DefaultRedisClusterClientOptions() *RedisClusterClientOptions
  • func (m *RedisClusterClientOptions) String() string

Functions

func InitRedisClient

func InitRedisClient(options ...option.Option) redis.UniversalClient

InitRedisClient init redis instance

func InitRedisClusterClient

func InitRedisClusterClient(options ...option.Option) redis.UniversalClient

InitRedisClusterClient init redis cluster instance

func WithGoRedisClusterOpts

func WithGoRedisClusterOpts(opts *redis.ClusterOptions) option.Option

func WithGoRedisOpts

func WithGoRedisOpts(opts *redis.Options) option.Option

func WithLimiter

func WithLimiter(limiter redis.Limiter) option.Option

func WithRedisAddr

func WithRedisAddr(addr string) option.Option

func WithRedisClientCommonOptions

func WithRedisClientCommonOptions(opts RedisClientCommonOptions) option.Option

func WithRedisClusterAddrs

func WithRedisClusterAddrs(addrs []string) option.Option

func WithRedisClusterRoute

func WithRedisClusterRoute(route string) option.Option

func WithRedisDB

func WithRedisDB(db int) option.Option

Types

type RedisClientCommonOptions

type RedisClientCommonOptions struct {
	Password string `mapstructure:"password"`
	Username string `mapstructure:"username"`

	MaxRetries      int           `mapstructure:"maxRetries"`
	MinRetryBackoff time.Duration `mapstructure:"minRetryBackoff"`
	MaxRetryBackoff time.Duration `mapstructure:"maxRetryBackoff"`
	DialTimeout     time.Duration `mapstructure:"dialTimeout"`
	ReadTimeout     time.Duration `mapstructure:"readTimeout"`
	WriteTimeout    time.Duration `mapstructure:"writeTimeout"`

	// connect pool
	PoolSize     int           `mapstructure:"poolSize"`
	MinIdleConns int           `mapstructure:"minIdleConns"`
	MaxIdleConns int           `mapstructure:"maxIdleConns"`
	MaxConnAge   time.Duration `mapstructure:"maxConnAge"`
	PoolTimeout  time.Duration `mapstructure:"poolTimeout"`
	IdleTimeout  time.Duration `mapstructure:"idleTimeout"`
}

func DefaultRedisClientCommonOptions

func DefaultRedisClientCommonOptions() *RedisClientCommonOptions

type RedisClientOptions

type RedisClientOptions struct {
	Addr string `mapstructure:"addr"`
	Db   int    `mapstructure:"db"`

	RedisClientCommonOptions
	// contains filtered or unexported fields
}

func DefaultRedisClientOptions

func DefaultRedisClientOptions() *RedisClientOptions

func (*RedisClientOptions) String

func (m *RedisClientOptions) String() string

type RedisClusterClientOptions

type RedisClusterClientOptions struct {
	Addrs []string `mapstructure:"addrs"`
	// To route commands by latency or randomly, enable one of the following.
	Route string `mapstructure:"route"`
	RedisClientCommonOptions
	// contains filtered or unexported fields
}

func DefaultRedisClusterClientOptions

func DefaultRedisClusterClientOptions() *RedisClusterClientOptions

func (*RedisClusterClientOptions) String

func (m *RedisClusterClientOptions) String() string