redis

Documentation

Index

• func NewRedisPool(host string, MaxIdle int, MaxActive int, idletimeout time.Duration) redis.Pool
• type DataFunc
• type RedisConn
  • func NewRedisConn(pool redis.Pool) RedisConn
  • func (rp *RedisConn) HandleCMDResultMessage(psc redis.PubSubConn, result chan string)
  • func (rp *RedisConn) HandleCommMessage(psc redis.PubSubConn, handleMessage DataFunc)
  • func (rp *RedisConn) Publish(channel, message string) (int, error)
  • func (rp *RedisConn) Subscribe(channel string) (redis.PubSubConn, error)

Functions

func NewRedisPool

func NewRedisPool(host string, MaxIdle int, MaxActive int, idletimeout time.Duration) redis.Pool

Types

type DataFunc

type DataFunc func(string)

type RedisConn

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

func NewRedisConn

func NewRedisConn(pool redis.Pool) RedisConn

func (*RedisConn) HandleCMDResultMessage

func (rp *RedisConn) HandleCMDResultMessage(psc redis.PubSubConn, result chan string)

处理命令结果消息

func (*RedisConn) HandleCommMessage

func (rp *RedisConn) HandleCommMessage(psc redis.PubSubConn, handleMessage DataFunc)

处理普通消息

func (*RedisConn) Publish

func (rp *RedisConn) Publish(channel, message string) (int, error)

func (*RedisConn) Subscribe

func (rp *RedisConn) Subscribe(channel string) (redis.PubSubConn, error)