redis_client

Documentation

Index

• func GetRedisClientManager() map[string]*RedisPool
• func InstallRedisClientManager(configs []RedisConfig)
• type RedisConfig
  • func (c *RedisConfig) ToRedisCacheConfig() string
• type RedisPool
  • func GetRedisClient(redisName string) (client *RedisPool)
  • func NewRedisPool(c *RedisConfig) (pool *RedisPool)
  • func (p *RedisPool) Close() error
  • func (p *RedisPool) Get() redis.Conn

Functions

func GetRedisClientManager

func GetRedisClientManager() map[string]*RedisPool

func InstallRedisClientManager

func InstallRedisClientManager(configs []RedisConfig)

Types

type RedisConfig

type RedisConfig struct {
	Name         string // redis name
	Addr         string
	Active       int // pool
	Idle         int // pool
	DialTimeout  base.Duration
	ReadTimeout  base.Duration
	WriteTimeout base.Duration
	IdleTimeout  base.Duration

	DBNum    string // db号
	Password string // 密码
}

Redis client config.

func (*RedisConfig) ToRedisCacheConfig

func (c *RedisConfig) ToRedisCacheConfig() string

type RedisPool

type RedisPool struct {
	*redis.Pool
	// contains filtered or unexported fields
}

func GetRedisClient

func GetRedisClient(redisName string) (client *RedisPool)

func NewRedisPool

func NewRedisPool(c *RedisConfig) (pool *RedisPool)

func (*RedisPool) Close

func (p *RedisPool) Close() error

func (*RedisPool) Get

func (p *RedisPool) Get() redis.Conn