gredigo

Documentation

Index

• Variables
• func AddRedisPool(name string, conf *RedisConf)
• func GetRedisClient(name string, timeoutCtx ...context.Context) redis.Conn
• func GetRedisClientWithTimeout(name string, ctx context.Context) redis.ConnWithTimeout
• func NewRedisPool(conf *RedisConf) *redis.Pool
• type ErrorConn
  • func (ec ErrorConn) Close() error
  • func (ec ErrorConn) Do(string, ...interface{}) (interface{}, error)
  • func (ec ErrorConn) DoWithTimeout(time.Duration, string, ...interface{}) (interface{}, error)
  • func (ec ErrorConn) Err() error
  • func (ec ErrorConn) Flush() error
  • func (ec ErrorConn) Receive() (interface{}, error)
  • func (ec ErrorConn) ReceiveWithTimeout(time.Duration) (interface{}, error)
  • func (ec ErrorConn) Send(string, ...interface{}) error
• type RedisConf
  • func (r *RedisConf) SetRedisPool(name string)

Variables

var (
	// ErrRedisConnectionNotFound redis connection not found
	ErrRedisConnectionNotFound = errors.New("redis connection not found")

	// ErrRedisConnectionInvalid redis connection invalid
	ErrRedisConnectionInvalid = errors.New("redis connection invalid")
)

var RedisPoolList = map[string]*redis.Pool{}

RedisPoolList 存放连接池信息

Functions

func AddRedisPool

func AddRedisPool(name string, conf *RedisConf)

AddRedisPool 添加新的redis连接池

func GetRedisClient

func GetRedisClient(name string, timeoutCtx ...context.Context) redis.Conn

GetRedisClient 通过指定name获取池子中的redis连接句柄

func GetRedisClientWithTimeout

func GetRedisClientWithTimeout(name string, ctx context.Context) redis.ConnWithTimeout

GetRedisClientWithTimeout return redis.ConnWithTimeout you can use DoWithTimeout method.

func NewRedisPool

func NewRedisPool(conf *RedisConf) *redis.Pool

NewRedisPool 创建redis pool连接池 If Wait is true and the pool is at the MaxActive limit, then Get() waits for a connection to be returned to the pool before returning.

TestOnBorrow is an optional application supplied function for checking the health of an idle connection before the connection is used again by the application. Argument t is the time that the connection was returned to the pool. If the function returns an error, then the connection is closed.

Types

type ErrorConn

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

ErrorConn error connection impl redis.Conn and redis.ConnWithTimeout

func (ErrorConn) Close

func (ec ErrorConn) Close() error

func (ErrorConn) Do

func (ec ErrorConn) Do(string, ...interface{}) (interface{}, error)

func (ErrorConn) DoWithTimeout

func (ec ErrorConn) DoWithTimeout(time.Duration, string, ...interface{}) (interface{}, error)

func (ErrorConn) Err

func (ec ErrorConn) Err() error

func (ErrorConn) Flush

func (ec ErrorConn) Flush() error

func (ErrorConn) Receive

func (ec ErrorConn) Receive() (interface{}, error)

func (ErrorConn) ReceiveWithTimeout

func (ec ErrorConn) ReceiveWithTimeout(time.Duration) (interface{}, error)

func (ErrorConn) Send

func (ec ErrorConn) Send(string, ...interface{}) error

type RedisConf

type RedisConf struct {
	Host           string
	Port           int
	Password       string
	Database       int
	MaxIdle        int // 空闲pool个数
	MaxActive      int // 最大激活数量
	ConnectTimeout int // 连接超时，单位s
	ReadTimeout    int // 读取超时
	WriteTimeout   int // 写入超时

	// Close connections after remaining idle for this duration. If the value
	// is zero, then idle connections are not closed. Applications should set
	// the timeout to a value less than the server's timeout.
	IdleTimeout int // 空闲连接超时,单位s

	// Close connections older than this duration. If the value is zero, then
	// the pool does not close connections based on age.
	MaxConnLifetime int // 连接最大生命周期,单位s，默认1800s
}

RedisConf redis连接信息 redigo实现集群参考： go get github.com/chasex/redis-go-cluster

func (*RedisConf) SetRedisPool

func (r *RedisConf) SetRedisPool(name string)

SetRedisPool 设置redis连接池