Documentation ¶
Index ¶
- Variables
- func HandleFuncPipe(handler func(pipe Pipeliner) error) func(pipe redis.Pipeliner) error
- func HandleFuncWatch(handler func(tx *TX) error) func(tx *redis.Tx) error
- type Cmder
- type Pipeliner
- type RedisCli
- func (rsc *RedisCli) RdbBLPop(waitTimeSecond uint64, keys ...string) ([]string, error)
- func (rsc *RedisCli) RdbBRPop(waitTimeSecond uint64, keys ...string) ([]string, error)
- func (rsc *RedisCli) RdbDel(keys ...string) (int64, error)
- func (rsc *RedisCli) RdbDelMatchKey(cursor uint64, match string, count int64) error
- func (rsc *RedisCli) RdbDo(args ...interface{}) (interface{}, error)
- func (rsc *RedisCli) RdbExists(keys ...string) (int64, error)
- func (rsc *RedisCli) RdbExpire(key string, expireTimeSecond uint64) (bool, error)
- func (rsc *RedisCli) RdbGet(key string) (string, error)
- func (rsc *RedisCli) RdbHDel(key string, fields ...string) (int64, error)
- func (rsc *RedisCli) RdbHGet(key, field string) (string, error)
- func (rsc *RedisCli) RdbHGetAll(key string) (map[string]string, error)
- func (rsc *RedisCli) RdbHSet(key string, values ...interface{}) error
- func (rsc *RedisCli) RdbKeys(pattern string) ([]string, error)
- func (rsc *RedisCli) RdbLPop(key string) (string, error)
- func (rsc *RedisCli) RdbLPush(key string, values ...interface{}) (int64, error)
- func (rsc *RedisCli) RdbRPop(key string) (string, error)
- func (rsc *RedisCli) RdbRPush(key string, values ...interface{}) (int64, error)
- func (rsc *RedisCli) RdbSet(key string, value interface{}, expireTimeSecond uint64) error
- func (rsc *RedisCli) RdbSetEx(key string, value interface{}, expireTimeSecond uint64) error
- func (rsc *RedisCli) RdbSetNx(key string, value interface{}, expireTimeSecond uint64) error
- func (rsc *RedisCli) RdbTTL(key string) (time.Duration, error)
- func (rsc *RedisCli) RdbTxPipelined(fn func(pipe Pipeliner) error) ([]Cmder, error)
- func (rsc *RedisCli) RdbWatch(fn func(tx *TX) error, keys ...string) error
- func (rsc *RedisCli) RdbZAdd(key string, members []map[string]float64) (int64, error)
- func (rsc *RedisCli) RdbZRange(key string, start, stop int64) ([]string, error)
- type RedisClusterCli
- func (rsc *RedisClusterCli) RdbBLPop(waitTimeSecond uint64, keys ...string) ([]string, error)
- func (rsc *RedisClusterCli) RdbBRPop(waitTimeSecond uint64, keys ...string) ([]string, error)
- func (rsc *RedisClusterCli) RdbDel(keys ...string) (int64, error)
- func (rsc *RedisClusterCli) RdbDelMatchKey(cursor uint64, match string, count int64) error
- func (rsc *RedisClusterCli) RdbDo(args ...interface{}) (interface{}, error)
- func (rsc *RedisClusterCli) RdbExists(keys ...string) (int64, error)
- func (rsc *RedisClusterCli) RdbExpire(key string, expireTimeSecond uint64) (bool, error)
- func (rsc *RedisClusterCli) RdbGet(key string) (string, error)
- func (rsc *RedisClusterCli) RdbHDel(key string, fields ...string) (int64, error)
- func (rsc *RedisClusterCli) RdbHGet(key, field string) (string, error)
- func (rsc *RedisClusterCli) RdbHGetAll(key string) (map[string]string, error)
- func (rsc *RedisClusterCli) RdbHSet(key string, values ...interface{}) error
- func (rsc *RedisClusterCli) RdbKeys(pattern string) ([]string, error)
- func (rsc *RedisClusterCli) RdbLPop(key string) (string, error)
- func (rsc *RedisClusterCli) RdbLPush(key string, values ...interface{}) (int64, error)
- func (rsc *RedisClusterCli) RdbRPop(key string) (string, error)
- func (rsc *RedisClusterCli) RdbRPush(key string, values ...interface{}) (int64, error)
- func (rsc *RedisClusterCli) RdbSet(key string, value interface{}, expireTimeSecond uint64) error
- func (rsc *RedisClusterCli) RdbSetEx(key string, value interface{}, expireTimeSecond uint64) error
- func (rsc *RedisClusterCli) RdbSetNx(key string, value interface{}, expireTimeSecond uint64) error
- func (rsc *RedisClusterCli) RdbTTL(key string) (time.Duration, error)
- func (rsc *RedisClusterCli) RdbTxPipelined(fn func(pipe Pipeliner) error) ([]Cmder, error)
- func (rsc *RedisClusterCli) RdbWatch(fn func(tx *TX) error, keys ...string) error
- func (rsc *RedisClusterCli) RdbZAdd(key string, members []map[string]float64) (int64, error)
- func (rsc *RedisClusterCli) RdbZRange(key string, start, stop int64) ([]string, error)
- type SentinelClient
- func (rsc *SentinelClient) RdbCkQuorum(name string) (string, error)
- func (rsc *SentinelClient) RdbFailover(name string) (string, error)
- func (rsc *SentinelClient) RdbFlushConfig() (string, error)
- func (rsc *SentinelClient) RdbGetMasterAddrByName(key string) ([]string, error)
- func (rsc *SentinelClient) RdbMaster(name string) (map[string]string, error)
- func (rsc *SentinelClient) RdbMasters(key string) ([]interface{}, error)
- func (rsc *SentinelClient) RdbMonitor(name, ip, port, quorum string) (string, error)
- func (rsc *SentinelClient) RdbPSubscribe(channels ...string) *redis.PubSub
- func (rsc *SentinelClient) RdbProcess(cmder Cmder) error
- func (rsc *SentinelClient) RdbRemove(name string) (string, error)
- func (rsc *SentinelClient) RdbReset(name string) (int64, error)
- func (rsc *SentinelClient) RdbSentinels(name string) (interface{}, error)
- func (rsc *SentinelClient) RdbSet(name, option, value string) error
- func (rsc *SentinelClient) RdbSlaves(name string) ([]interface{}, error)
- func (rsc *SentinelClient) RdbSubscribe(name string) *redis.PubSub
- type TX
- type UniversalClient
- func (rsc *UniversalClient) RdbBLPop(waitTimeSecond uint64, keys ...string) ([]string, error)
- func (rsc *UniversalClient) RdbBRPop(waitTimeSecond uint64, keys ...string) ([]string, error)
- func (rsc *UniversalClient) RdbDel(keys ...string) (int64, error)
- func (rsc *UniversalClient) RdbDelMatchKey(cursor uint64, match string, count int64) error
- func (rsc *UniversalClient) RdbDo(args ...interface{}) (interface{}, error)
- func (rsc UniversalClient) RdbExists(keys ...string) (int64, error)
- func (rsc *UniversalClient) RdbExpire(key string, expireTimeSecond uint64) (bool, error)
- func (rsc *UniversalClient) RdbGet(key string) (string, error)
- func (rsc *UniversalClient) RdbHDel(key string, fields ...string) (int64, error)
- func (rsc *UniversalClient) RdbHGet(key, field string) (string, error)
- func (rsc *UniversalClient) RdbHGetAll(key string) (map[string]string, error)
- func (rsc *UniversalClient) RdbHSet(key string, values ...interface{}) error
- func (rsc *UniversalClient) RdbKeys(pattern string) ([]string, error)
- func (rsc *UniversalClient) RdbLPop(key string) (string, error)
- func (rsc *UniversalClient) RdbLPush(key string, values ...interface{}) (int64, error)
- func (rsc *UniversalClient) RdbRPop(key string) (string, error)
- func (rsc *UniversalClient) RdbRPush(key string, values ...interface{}) (int64, error)
- func (rsc *UniversalClient) RdbSet(key string, value interface{}, expireTimeSecond uint64) error
- func (rsc *UniversalClient) RdbSetEx(key string, value interface{}, expireTimeSecond uint64) error
- func (rsc *UniversalClient) RdbSetNx(key string, value interface{}, expireTimeSecond uint64) error
- func (rsc *UniversalClient) RdbTTL(key string) (time.Duration, error)
- func (rsc *UniversalClient) RdbTxPipelined(fn func(pipe Pipeliner) error) ([]Cmder, error)
- func (rsc *UniversalClient) RdbWatch(fn func(tx *TX) error, keys ...string) error
- func (rsc *UniversalClient) RdbZAdd(key string, members []map[string]float64) (int64, error)
- func (rsc *UniversalClient) RdbZRange(key string, start, stop int64) ([]string, error)
- type UniversalOptions
Constants ¶
This section is empty.
Variables ¶
View Source
var CtxExpireTime = 5 * time.Second
Functions ¶
func HandleFuncPipe ¶
func HandleFuncWatch ¶
Types ¶
type RedisCli ¶
type RedisCli struct {
*redis.Client
}
func InitRedisFailover ¶
func (*RedisCli) RdbDelMatchKey ¶
func (*RedisCli) RdbHGetAll ¶
func (*RedisCli) RdbTxPipelined ¶
type RedisClusterCli ¶
type RedisClusterCli struct {
*redis.ClusterClient
}
func InitRedisCluster ¶
func InitRedisCluster(addrs []string, poolSize, idleConns int, username, password string) *RedisClusterCli
func (*RedisClusterCli) RdbBLPop ¶
func (rsc *RedisClusterCli) RdbBLPop(waitTimeSecond uint64, keys ...string) ([]string, error)
func (*RedisClusterCli) RdbBRPop ¶
func (rsc *RedisClusterCli) RdbBRPop(waitTimeSecond uint64, keys ...string) ([]string, error)
func (*RedisClusterCli) RdbDelMatchKey ¶
func (rsc *RedisClusterCli) RdbDelMatchKey(cursor uint64, match string, count int64) error
func (*RedisClusterCli) RdbDo ¶
func (rsc *RedisClusterCli) RdbDo(args ...interface{}) (interface{}, error)
func (*RedisClusterCli) RdbExists ¶
func (rsc *RedisClusterCli) RdbExists(keys ...string) (int64, error)
func (*RedisClusterCli) RdbExpire ¶
func (rsc *RedisClusterCli) RdbExpire(key string, expireTimeSecond uint64) (bool, error)
func (*RedisClusterCli) RdbHDel ¶
func (rsc *RedisClusterCli) RdbHDel(key string, fields ...string) (int64, error)
func (*RedisClusterCli) RdbHGet ¶
func (rsc *RedisClusterCli) RdbHGet(key, field string) (string, error)
func (*RedisClusterCli) RdbHGetAll ¶
func (rsc *RedisClusterCli) RdbHGetAll(key string) (map[string]string, error)
func (*RedisClusterCli) RdbHSet ¶
func (rsc *RedisClusterCli) RdbHSet(key string, values ...interface{}) error
func (*RedisClusterCli) RdbKeys ¶
func (rsc *RedisClusterCli) RdbKeys(pattern string) ([]string, error)
func (*RedisClusterCli) RdbLPush ¶
func (rsc *RedisClusterCli) RdbLPush(key string, values ...interface{}) (int64, error)
func (*RedisClusterCli) RdbRPush ¶
func (rsc *RedisClusterCli) RdbRPush(key string, values ...interface{}) (int64, error)
func (*RedisClusterCli) RdbSet ¶
func (rsc *RedisClusterCli) RdbSet(key string, value interface{}, expireTimeSecond uint64) error
func (*RedisClusterCli) RdbSetEx ¶
func (rsc *RedisClusterCli) RdbSetEx(key string, value interface{}, expireTimeSecond uint64) error
func (*RedisClusterCli) RdbSetNx ¶
func (rsc *RedisClusterCli) RdbSetNx(key string, value interface{}, expireTimeSecond uint64) error
func (*RedisClusterCli) RdbTTL ¶
func (rsc *RedisClusterCli) RdbTTL(key string) (time.Duration, error)
func (*RedisClusterCli) RdbTxPipelined ¶
func (rsc *RedisClusterCli) RdbTxPipelined(fn func(pipe Pipeliner) error) ([]Cmder, error)
func (*RedisClusterCli) RdbWatch ¶
func (rsc *RedisClusterCli) RdbWatch(fn func(tx *TX) error, keys ...string) error
type SentinelClient ¶
type SentinelClient struct {
*redis.SentinelClient
}
func InitRedisSentinel ¶
func InitRedisSentinel(addr string, db, poolSize, idleConns int, username, password string) *SentinelClient
func (*SentinelClient) RdbCkQuorum ¶
func (rsc *SentinelClient) RdbCkQuorum(name string) (string, error)
func (*SentinelClient) RdbFailover ¶
func (rsc *SentinelClient) RdbFailover(name string) (string, error)
func (*SentinelClient) RdbFlushConfig ¶
func (rsc *SentinelClient) RdbFlushConfig() (string, error)
func (*SentinelClient) RdbGetMasterAddrByName ¶
func (rsc *SentinelClient) RdbGetMasterAddrByName(key string) ([]string, error)
func (*SentinelClient) RdbMaster ¶
func (rsc *SentinelClient) RdbMaster(name string) (map[string]string, error)
func (*SentinelClient) RdbMasters ¶
func (rsc *SentinelClient) RdbMasters(key string) ([]interface{}, error)
func (*SentinelClient) RdbMonitor ¶
func (rsc *SentinelClient) RdbMonitor(name, ip, port, quorum string) (string, error)
func (*SentinelClient) RdbPSubscribe ¶
func (rsc *SentinelClient) RdbPSubscribe(channels ...string) *redis.PubSub
func (*SentinelClient) RdbProcess ¶
func (rsc *SentinelClient) RdbProcess(cmder Cmder) error
func (*SentinelClient) RdbRemove ¶
func (rsc *SentinelClient) RdbRemove(name string) (string, error)
func (*SentinelClient) RdbSentinels ¶
func (rsc *SentinelClient) RdbSentinels(name string) (interface{}, error)
func (*SentinelClient) RdbSet ¶
func (rsc *SentinelClient) RdbSet(name, option, value string) error
func (*SentinelClient) RdbSlaves ¶
func (rsc *SentinelClient) RdbSlaves(name string) ([]interface{}, error)
func (*SentinelClient) RdbSubscribe ¶
func (rsc *SentinelClient) RdbSubscribe(name string) *redis.PubSub
type UniversalClient ¶
type UniversalClient struct {
redis.UniversalClient
}
func InitRedisUniversal ¶
func InitRedisUniversal(ops UniversalOptions) *UniversalClient
func (*UniversalClient) RdbBLPop ¶
func (rsc *UniversalClient) RdbBLPop(waitTimeSecond uint64, keys ...string) ([]string, error)
func (*UniversalClient) RdbBRPop ¶
func (rsc *UniversalClient) RdbBRPop(waitTimeSecond uint64, keys ...string) ([]string, error)
func (*UniversalClient) RdbDelMatchKey ¶
func (rsc *UniversalClient) RdbDelMatchKey(cursor uint64, match string, count int64) error
func (*UniversalClient) RdbDo ¶
func (rsc *UniversalClient) RdbDo(args ...interface{}) (interface{}, error)
func (UniversalClient) RdbExists ¶
func (rsc UniversalClient) RdbExists(keys ...string) (int64, error)
func (*UniversalClient) RdbExpire ¶
func (rsc *UniversalClient) RdbExpire(key string, expireTimeSecond uint64) (bool, error)
func (*UniversalClient) RdbHDel ¶
func (rsc *UniversalClient) RdbHDel(key string, fields ...string) (int64, error)
func (*UniversalClient) RdbHGet ¶
func (rsc *UniversalClient) RdbHGet(key, field string) (string, error)
func (*UniversalClient) RdbHGetAll ¶
func (rsc *UniversalClient) RdbHGetAll(key string) (map[string]string, error)
func (*UniversalClient) RdbHSet ¶
func (rsc *UniversalClient) RdbHSet(key string, values ...interface{}) error
func (*UniversalClient) RdbKeys ¶
func (rsc *UniversalClient) RdbKeys(pattern string) ([]string, error)
func (*UniversalClient) RdbLPush ¶
func (rsc *UniversalClient) RdbLPush(key string, values ...interface{}) (int64, error)
func (*UniversalClient) RdbRPush ¶
func (rsc *UniversalClient) RdbRPush(key string, values ...interface{}) (int64, error)
func (*UniversalClient) RdbSet ¶
func (rsc *UniversalClient) RdbSet(key string, value interface{}, expireTimeSecond uint64) error
func (*UniversalClient) RdbSetEx ¶
func (rsc *UniversalClient) RdbSetEx(key string, value interface{}, expireTimeSecond uint64) error
func (*UniversalClient) RdbSetNx ¶
func (rsc *UniversalClient) RdbSetNx(key string, value interface{}, expireTimeSecond uint64) error
func (*UniversalClient) RdbTTL ¶
func (rsc *UniversalClient) RdbTTL(key string) (time.Duration, error)
func (*UniversalClient) RdbTxPipelined ¶
func (rsc *UniversalClient) RdbTxPipelined(fn func(pipe Pipeliner) error) ([]Cmder, error)
func (*UniversalClient) RdbWatch ¶
func (rsc *UniversalClient) RdbWatch(fn func(tx *TX) error, keys ...string) error
type UniversalOptions ¶
type UniversalOptions struct {
*redis.UniversalOptions
}
Click to show internal directories.
Click to hide internal directories.