Documentation
¶
Index ¶
- func GetConn() (c redis.Conn)
- func Init(conf *RedisConfig)
- func TryRedisCmd(ctx context.Context, strategy retry.ResettableStrategy, cmd string, ...) (reply interface{}, err error)
- func TryRedisScript(ctx context.Context, strategy retry.ResettableStrategy, script *redis.Script, ...) (reply interface{}, err error)
- func Uninit()
- type RedisConfig
- type RedisConnectionManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func TryRedisCmd ¶
func TryRedisCmd(ctx context.Context, strategy retry.ResettableStrategy, cmd string, args ...interface{}) (reply interface{}, err error)
TryRedisCmd retry a redis command with respect of the circuit breaker status
func TryRedisScript ¶
func TryRedisScript(ctx context.Context, strategy retry.ResettableStrategy, script *redis.Script, keysAndArgs ...interface{}) (reply interface{}, err error)
TryRedisScript run a lua script with the respect of the circuit breaker status
Types ¶
type RedisConfig ¶
type RedisConfig struct {
Addrs []string
MaxIdle int
MaxActive int
ConnectTimeout time.Duration
ReadTimeout time.Duration
WriteTimeout time.Duration
IdleTimeout time.Duration
Wait bool
}
RedisConfig defines the redis config
type RedisConnectionManager ¶
type RedisConnectionManager struct {
// contains filtered or unexported fields
}
RedisConnectionManager is the redis connection manager
Click to show internal directories.
Click to hide internal directories.