redisc

package
v0.1.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 10, 2024 License: Apache-2.0 Imports: 4 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CtxExpireTime = 5 * time.Second

Functions

func HandleFuncPipe 

func HandleFuncPipe(handler func(pipe Pipeliner) error) func(pipe redis.Pipeliner) error

func HandleFuncWatch 

func HandleFuncWatch(handler func(tx *TX) error) func(tx *redis.Tx) error

Types

type Cmder 

type Cmder interface {
	redis.Cmder
}

type Pipeliner 

type Pipeliner interface {
	redis.Pipeliner
}

type RedisCli 

type RedisCli struct {
	*redis.Client
}

func InitRedis 

func InitRedis(addr string, db, poolSize, idleConns int, username, password string) *RedisCli

func InitRedisFailover 

func InitRedisFailover(masterName string, sentinelAddrs []string, db, poolSize, idleConns int, username, password, sentinelUsername, sentinelPassword string) *RedisCli

func (*RedisCli) RdbBLPop 

func (rsc *RedisCli) RdbBLPop(waitTimeSecond uint64, keys ...string) ([]string, error)

func (*RedisCli) RdbBRPop 

func (rsc *RedisCli) RdbBRPop(waitTimeSecond uint64, keys ...string) ([]string, error)

func (*RedisCli) RdbDel 

func (rsc *RedisCli) RdbDel(keys ...string) (int64, error)

func (*RedisCli) RdbDelMatchKey 

func (rsc *RedisCli) RdbDelMatchKey(cursor uint64, match string, count int64) error

func (*RedisCli) RdbDo 

func (rsc *RedisCli) RdbDo(args ...interface{}) (interface{}, error)

func (*RedisCli) RdbExists 

func (rsc *RedisCli) RdbExists(keys ...string) (int64, error)

func (*RedisCli) RdbExpire 

func (rsc *RedisCli) RdbExpire(key string, expireTimeSecond uint64) (bool, error)

func (*RedisCli) RdbGet 

func (rsc *RedisCli) RdbGet(key string) (string, error)

func (*RedisCli) RdbHDel 

func (rsc *RedisCli) RdbHDel(key string, fields ...string) (int64, error)

func (*RedisCli) RdbHGet 

func (rsc *RedisCli) RdbHGet(key, field string) (string, error)

func (*RedisCli) RdbHGetAll 

func (rsc *RedisCli) RdbHGetAll(key string) (map[string]string, error)

func (*RedisCli) RdbHSet 

func (rsc *RedisCli) RdbHSet(key string, values ...interface{}) error

func (*RedisCli) RdbKeys 

func (rsc *RedisCli) RdbKeys(pattern string) ([]string, error)

func (*RedisCli) RdbLPop 

func (rsc *RedisCli) RdbLPop(key string) (string, error)

func (*RedisCli) RdbLPush 

func (rsc *RedisCli) RdbLPush(key string, values ...interface{}) (int64, error)

func (*RedisCli) RdbRPop 

func (rsc *RedisCli) RdbRPop(key string) (string, error)

func (*RedisCli) RdbRPush 

func (rsc *RedisCli) RdbRPush(key string, values ...interface{}) (int64, error)

func (*RedisCli) RdbSet 

func (rsc *RedisCli) RdbSet(key string, value interface{}, expireTimeSecond uint64) error

func (*RedisCli) RdbSetEx 

func (rsc *RedisCli) RdbSetEx(key string, value interface{}, expireTimeSecond uint64) error

func (*RedisCli) RdbSetNx 

func (rsc *RedisCli) RdbSetNx(key string, value interface{}, expireTimeSecond uint64) error

func (*RedisCli) RdbTTL 

func (rsc *RedisCli) RdbTTL(key string) (time.Duration, error)

func (*RedisCli) RdbTxPipelined 

func (rsc *RedisCli) RdbTxPipelined(fn func(pipe Pipeliner) error) ([]Cmder, error)

func (*RedisCli) RdbWatch 

func (rsc *RedisCli) RdbWatch(fn func(tx *TX) error, keys ...string) error

func (*RedisCli) RdbZAdd 

func (rsc *RedisCli) RdbZAdd(key string, members []map[string]float64) (int64, error)

func (*RedisCli) RdbZRange 

func (rsc *RedisCli) RdbZRange(key string, start, stop int64) ([]string, error)

type RedisClusterCli 

type RedisClusterCli struct {
	*redis.ClusterClient
}

func InitRedisCluster 

func InitRedisCluster(addrs []string, poolSize, idleConns int, username, password string) *RedisClusterCli

func InitRedisFailoverCluster 

func InitRedisFailoverCluster(masterName string, sentinelAddrs []string, isRandom bool, db, poolSize, idleConns int, username, password, sentinelUsername, sentinelPassword 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) RdbDel 

func (rsc *RedisClusterCli) RdbDel(keys ...string) (int64, 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) RdbGet 

func (rsc *RedisClusterCli) RdbGet(key string) (string, 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) RdbLPop 

func (rsc *RedisClusterCli) RdbLPop(key string) (string, error)

func (*RedisClusterCli) RdbLPush 

func (rsc *RedisClusterCli) RdbLPush(key string, values ...interface{}) (int64, error)

func (*RedisClusterCli) RdbRPop 

func (rsc *RedisClusterCli) RdbRPop(key string) (string, 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

func (*RedisClusterCli) RdbZAdd 

func (rsc *RedisClusterCli) RdbZAdd(key string, members []map[string]float64) (int64, error)

func (*RedisClusterCli) RdbZRange 

func (rsc *RedisClusterCli) RdbZRange(key string, start, stop int64) ([]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) RdbReset 

func (rsc *SentinelClient) RdbReset(name string) (int64, 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 TX 

type TX struct {
	*redis.Tx
}

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) RdbDel 

func (rsc *UniversalClient) RdbDel(keys ...string) (int64, 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) RdbGet 

func (rsc *UniversalClient) RdbGet(key string) (string, 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) RdbLPop 

func (rsc *UniversalClient) RdbLPop(key string) (string, error)

func (*UniversalClient) RdbLPush 

func (rsc *UniversalClient) RdbLPush(key string, values ...interface{}) (int64, error)

func (*UniversalClient) RdbRPop 

func (rsc *UniversalClient) RdbRPop(key string) (string, 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

func (*UniversalClient) RdbZAdd 

func (rsc *UniversalClient) RdbZAdd(key string, members []map[string]float64) (int64, error)

func (*UniversalClient) RdbZRange 

func (rsc *UniversalClient) RdbZRange(key string, start, stop int64) ([]string, error)

type UniversalOptions 

type UniversalOptions struct {
	*redis.UniversalOptions
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.