redis

Documentation

Index

• type RedisClient
  • func (r *RedisClient) Check() error
  • func (r *RedisClient) Close()
  • func (r *RedisClient) GetConnection(dbName ...string) (redis.UniversalClient, error)
  • func (r *RedisClient) Init(redisConfigUrl string)
  • func (r *RedisClient) IsMultiDB() bool
  • func (r *RedisClient) ListConnNames() []string
  • func (r *RedisClient) PSubscribe(dbName string, handler func(msg *redis.Message, dbName string), ...)

Types

type RedisClient

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

func (*RedisClient) Check

func (r *RedisClient) Check() error

func (*RedisClient) Close

func (r *RedisClient) Close()

func (*RedisClient) GetConnection

func (r *RedisClient) GetConnection(dbName ...string) (redis.UniversalClient, error)

func (*RedisClient) Init

func (r *RedisClient) Init(redisConfigUrl string)

func (*RedisClient) IsMultiDB

func (r *RedisClient) IsMultiDB() bool

func (*RedisClient) ListConnNames

func (r *RedisClient) ListConnNames() []string

func (*RedisClient) PSubscribe

func (r *RedisClient) PSubscribe(dbName string, handler func(msg *redis.Message, dbName string), channels ...string)

PSubscribe 订阅消息并自动重连