cache

May 1, 2020

Changes in this version

+ const DEL

+ const DefaultConnectTimout

+ const DefaultIdleTimeout

+ const DefaultMaxActive

+ const DefaultMaxIdle

+ const DefaultReadTimeout

+ const DefaultWriteTimeout

+ const EXISTS

+ const EXPIRE

+ const GET

+ const HDEL

+ const HGETALL

+ const HINCRBY

+ const INCR

+ const INCRBY

+ const ReplyOK

+ const SET

+ const SETEX

+ const ZADD

+ const ZCARD

+ const ZRANGE

+ const ZREM

+ func CheckNilErr(err error) (bool, error)

+ func MsgPackDecodeBytes(bytes []byte, dest interface{}) (err error)

+ func MsgPackEncodeBytes(data interface{}) (bytes []byte, err error)

+ func TryLock(lockKey string, lockSencods int, paramConf *ParamConf, ...) (bool, error)

+ func UnLock(lockKey string, paramConf *ParamConf, redisClient *RedisClient) error

+ type Param interface

+ Expire func() int

+ Group func() string

+ Key func() string

+ type ParamConf struct

+ func NewParamConf(group, keyPrefix string, expire int) *ParamConf

+ func (p *ParamConf) Expire() int

+ func (p *ParamConf) Group() string

+ func (p *ParamConf) KeyPrefix() string

+ func (p *ParamConf) NewParamKey(key string) *ParamKey

+ func (p *ParamConf) NewParamKeyWithoutPrefix(key string) *ParamKey

+ func (p *ParamConf) NewWithExpire(expire int) *ParamConf

+ func (p *ParamConf) NewWithKeyPrefix(keyPrefix string) *ParamConf

+ type ParamKey struct

+ func (p *ParamKey) Key() string

+ func (p *ParamKey) NewWithExpire(expire int) *ParamKey

+ type Pipeline struct

+ func NewPipeline(r *RedisClient) (*Pipeline, error)

+ func (p *Pipeline) Close()

+ func (p *Pipeline) Flush() error

+ func (p *Pipeline) Receive() (replies []*PipelineReply, err error)

+ func (p *Pipeline) Send(param Param, command string, args ...interface{}) error

+ type PipelineReply struct

+ Err error

+ Reply interface{}

+ type RedisClient struct

+ func NewRedisClient(groups map[string][]*RedisServer) *RedisClient

+ func NewRedisClientWithConf(conf *RedisConf) *RedisClient

+ func (p *RedisClient) Del(param Param) (deleted bool, err error)

+ func (p *RedisClient) Do(param Param, fn func(conn redis.Conn) (interface{}, error)) (reply interface{}, err error)

+ func (p *RedisClient) Eval(param Param, script *redis.Script, args ...interface{}) (reply interface{}, err error)

+ func (p *RedisClient) Exists(param Param) (exists bool, err error)

+ func (p *RedisClient) Expire(param Param) (expired bool, err error)

+ func (p *RedisClient) Get(param Param) (reply interface{}, ok bool, err error)

+ func (p *RedisClient) GetConn(param Param) (conn redis.Conn, err error)

+ func (p *RedisClient) GetFloat64(param Param) (reply float64, ok bool, err error)

+ func (p *RedisClient) GetGroupServers(group string) ([]*RedisServer, error)

+ func (p *RedisClient) GetInt(param Param) (reply int, ok bool, err error)

+ func (p *RedisClient) GetInt64(param Param) (reply int64, ok bool, err error)

+ func (p *RedisClient) GetObject(param Param, dest interface{}) (ok bool, err error)

+ func (p *RedisClient) GetObjects(paramConf *ParamConf, keys []string, dest interface{}, ...) error

+ func (p *RedisClient) GetString(param Param) (reply string, ok bool, err error)

+ func (p *RedisClient) Incr(param Param) (val int64, err error)

+ func (p *RedisClient) IncrBy(param Param, increment int64) (val int64, err error)

+ func (p *RedisClient) Set(param Param, data interface{}) error

+ func (p *RedisClient) SetObject(param Param, data interface{}) error

+ func (p *RedisClient) TTL(param Param) (val int, err error)

+ type RedisConf struct

+ GroupPool map[string]*RedisPoolConf

+ Groups map[string][]string

+ Pool *RedisPoolConf

+ Servers []*RedisServer

+ func (p *RedisConf) Parse() error

+ func (p *RedisConf) RedisConfig() *RedisConf

+ type RedisConfigurer interface

+ RedisConfig func() *RedisConf

+ type RedisPoolConf struct

+ ConnectTimeout int

+ IdleTimeout int

+ MaxActive int

+ MaxIdle int

+ ReadTimeout int

+ WriteTimeout int

+ type RedisServer struct

+ Auth string

+ Host string

+ ID string

+ Port int

+ func (p *RedisServer) GetConn() (redis.Conn, error)