Documentation ¶
Index ¶
- type Client
- func (cli *Client) Append(key, value string) *redis.IntCmd
- func (cli *Client) BLMove(source, destination, srcpos, destpos string, timeout time.Duration) *redis.StringCmd
- func (cli *Client) BLPop(timeout time.Duration, keys ...string) *redis.StringSliceCmd
- func (cli *Client) BRPop(timeout time.Duration, keys ...string) *redis.StringSliceCmd
- func (cli *Client) BRPopLPush(source, destination string, timeout time.Duration) *redis.StringCmd
- func (cli *Client) BZPopMax(timeout time.Duration, keys ...string) *redis.ZWithKeyCmd
- func (cli *Client) BZPopMin(timeout time.Duration, keys ...string) *redis.ZWithKeyCmd
- func (cli *Client) BitCount(key string, bitCount *redis.BitCount) *redis.IntCmd
- func (cli *Client) BitField(key string, args ...interface{}) *redis.IntSliceCmd
- func (cli *Client) BitOpAnd(destKey string, keys ...string) *redis.IntCmd
- func (cli *Client) BitOpNot(destKey string, key string) *redis.IntCmd
- func (cli *Client) BitOpOr(destKey string, keys ...string) *redis.IntCmd
- func (cli *Client) BitOpXor(destKey string, keys ...string) *redis.IntCmd
- func (cli *Client) BitPos(key string, bit int64, pos ...int64) *redis.IntCmd
- func (cli *Client) ClientGetName() *redis.StringCmd
- func (cli *Client) ClientKill(ipPort string) *redis.StatusCmd
- func (cli *Client) ClientKillByFilter(keys ...string) *redis.IntCmd
- func (cli *Client) ClientPause(dur time.Duration) *redis.BoolCmd
- func (cli *Client) ClusterAddSlots(slots ...int) *redis.StatusCmd
- func (cli *Client) ClusterAddSlotsRange(min, max int) *redis.StatusCmd
- func (cli *Client) ClusterCountFailureReports(nodeID string) *redis.IntCmd
- func (cli *Client) ClusterCountKeysInSlot(slot int) *redis.IntCmd
- func (cli *Client) ClusterDelSlots(slots ...int) *redis.StatusCmd
- func (cli *Client) ClusterDelSlotsRange(min, max int) *redis.StatusCmd
- func (cli *Client) ClusterForget(nodeID string) *redis.StatusCmd
- func (cli *Client) ClusterGetKeysInSlot(slot int, count int) *redis.StringSliceCmd
- func (cli *Client) ClusterKeySlot(key string) *redis.IntCmd
- func (cli *Client) ClusterMeet(host, port string) *redis.StatusCmd
- func (cli *Client) ClusterReplicate(nodeID string) *redis.StatusCmd
- func (cli *Client) ClusterSlaves(nodeID string) *redis.StringSliceCmd
- func (cli *Client) Command() *redis.CommandsInfoCmd
- func (cli *Client) ConfigGet(parameter string) *redis.SliceCmd
- func (cli *Client) ConfigSet(parameter, value string) *redis.StatusCmd
- func (cli *Client) Copy(sourceKey string, destKey string, db int, replace bool) *redis.IntCmd
- func (cli *Client) DebugObject(key string) *redis.StringCmd
- func (cli *Client) Decr(key string) *redis.IntCmd
- func (cli *Client) DecrBy(key string, decrement int64) *redis.IntCmd
- func (cli *Client) Del(keys ...string) *redis.IntCmd
- func (cli *Client) Dump(key string) *redis.StringCmd
- func (cli *Client) Echo(message interface{}) *redis.StringCmd
- func (cli *Client) Eval(script string, keys []string, args ...interface{}) *redis.Cmd
- func (cli *Client) EvalSha(sha1 string, keys []string, args ...interface{}) *redis.Cmd
- func (cli *Client) Exists(keys ...string) *redis.IntCmd
- func (cli *Client) Expire(key string, expiration time.Duration) *redis.BoolCmd
- func (cli *Client) ExpireAt(key string, tm time.Time) *redis.BoolCmd
- func (cli *Client) ExpireGT(key string, expiration time.Duration) *redis.BoolCmd
- func (cli *Client) ExpireLT(key string, expiration time.Duration) *redis.BoolCmd
- func (cli *Client) ExpireNX(key string, expiration time.Duration) *redis.BoolCmd
- func (cli *Client) ExpireXX(key string, expiration time.Duration) *redis.BoolCmd
- func (cli *Client) GeoAdd(key string, geoLocation ...*redis.GeoLocation) *redis.IntCmd
- func (cli *Client) GeoDist(key string, member1, member2, unit string) *redis.FloatCmd
- func (cli *Client) GeoHash(key string, members ...string) *redis.StringSliceCmd
- func (cli *Client) GeoPos(key string, members ...string) *redis.GeoPosCmd
- func (cli *Client) GeoRadius(key string, longitude, latitude float64, query *redis.GeoRadiusQuery) *redis.GeoLocationCmd
- func (cli *Client) GeoRadiusByMember(key, member string, query *redis.GeoRadiusQuery) *redis.GeoLocationCmd
- func (cli *Client) GeoRadiusByMemberStore(key, member string, query *redis.GeoRadiusQuery) *redis.IntCmd
- func (cli *Client) GeoRadiusStore(key string, longitude, latitude float64, query *redis.GeoRadiusQuery) *redis.IntCmd
- func (cli *Client) GeoSearch(key string, q *redis.GeoSearchQuery) *redis.StringSliceCmd
- func (cli *Client) GeoSearchLocation(key string, q *redis.GeoSearchLocationQuery) *redis.GeoSearchLocationCmd
- func (cli *Client) GeoSearchStore(key, store string, q *redis.GeoSearchStoreQuery) *redis.IntCmd
- func (cli *Client) Get(key string) *redis.StringCmd
- func (cli *Client) GetBit(key string, offset int64) *redis.IntCmd
- func (cli *Client) GetDel(key string) *redis.StringCmd
- func (cli *Client) GetEx(key string, expiration time.Duration) *redis.StringCmd
- func (cli *Client) GetRange(key string, start, end int64) *redis.StringCmd
- func (cli *Client) GetSet(key string, value interface{}) *redis.StringCmd
- func (cli *Client) HDel(key string, fields ...string) *redis.IntCmd
- func (cli *Client) HExists(key, field string) *redis.BoolCmd
- func (cli *Client) HGet(key, field string) *redis.StringCmd
- func (cli *Client) HGetAll(key string) *redis.StringStringMapCmd
- func (cli *Client) HIncrBy(key, field string, incr int64) *redis.IntCmd
- func (cli *Client) HIncrByFloat(key, field string, incr float64) *redis.FloatCmd
- func (cli *Client) HKeys(key string) *redis.StringSliceCmd
- func (cli *Client) HLen(key string) *redis.IntCmd
- func (cli *Client) HMGet(key string, fields ...string) *redis.SliceCmd
- func (cli *Client) HMSet(key string, values ...interface{}) *redis.BoolCmd
- func (cli *Client) HRandField(key string, count int, withValues bool) *redis.StringSliceCmd
- func (cli *Client) HScan(key string, cursor uint64, match string, count int64) *redis.ScanCmd
- func (cli *Client) HSet(key string, values ...interface{}) *redis.IntCmd
- func (cli *Client) HSetNX(key, field string, value interface{}) *redis.BoolCmd
- func (cli *Client) HVals(key string) *redis.StringSliceCmd
- func (cli *Client) Incr(key string) *redis.IntCmd
- func (cli *Client) IncrBy(key string, value int64) *redis.IntCmd
- func (cli *Client) IncrByFloat(key string, value float64) *redis.FloatCmd
- func (cli *Client) Info(section ...string) *redis.StringCmd
- func (cli *Client) Keys(pattern string) *redis.StringSliceCmd
- func (cli *Client) LIndex(key string, index int64) *redis.StringCmd
- func (cli *Client) LInsert(key, op string, pivot, value interface{}) *redis.IntCmd
- func (cli *Client) LInsertAfter(key string, pivot, value interface{}) *redis.IntCmd
- func (cli *Client) LInsertBefore(key string, pivot, value interface{}) *redis.IntCmd
- func (cli *Client) LLen(key string) *redis.IntCmd
- func (cli *Client) LMove(source, destination, srcpos, destpos string) *redis.StringCmd
- func (cli *Client) LPop(key string) *redis.StringCmd
- func (cli *Client) LPopCount(key string, count int) *redis.StringSliceCmd
- func (cli *Client) LPos(key string, value string, args redis.LPosArgs) *redis.IntCmd
- func (cli *Client) LPosCount(key string, value string, count int64, args redis.LPosArgs) *redis.IntSliceCmd
- func (cli *Client) LPush(key string, values ...interface{}) *redis.IntCmd
- func (cli *Client) LPushX(key string, values ...interface{}) *redis.IntCmd
- func (cli *Client) LRange(key string, start, stop int64) *redis.StringSliceCmd
- func (cli *Client) LRem(key string, count int64, value interface{}) *redis.IntCmd
- func (cli *Client) LSet(key string, index int64, value interface{}) *redis.StatusCmd
- func (cli *Client) LTrim(key string, start, stop int64) *redis.StatusCmd
- func (cli *Client) MGet(keys ...string) *redis.SliceCmd
- func (cli *Client) MSet(values ...interface{}) *redis.StatusCmd
- func (cli *Client) MSetNX(values ...interface{}) *redis.BoolCmd
- func (cli *Client) MemoryUsage(key string, samples ...int) *redis.IntCmd
- func (cli *Client) Migrate(host, port, key string, db int, timeout time.Duration) *redis.StatusCmd
- func (cli *Client) Move(key string, db int) *redis.BoolCmd
- func (cli *Client) ObjectEncoding(key string) *redis.StringCmd
- func (cli *Client) ObjectIdleTime(key string) *redis.DurationCmd
- func (cli *Client) ObjectRefCount(key string) *redis.IntCmd
- func (cli *Client) PExpire(key string, expiration time.Duration) *redis.BoolCmd
- func (cli *Client) PExpireAt(key string, tm time.Time) *redis.BoolCmd
- func (cli *Client) PFAdd(key string, els ...interface{}) *redis.IntCmd
- func (cli *Client) PFCount(keys ...string) *redis.IntCmd
- func (cli *Client) PFMerge(dest string, keys ...string) *redis.StatusCmd
- func (cli *Client) PTTL(key string) *redis.DurationCmd
- func (cli *Client) Persist(key string) *redis.BoolCmd
- func (cli *Client) Ping() *redis.StatusCmd
- func (cli *Client) Pipelined(fn func(redis.Pipeliner) error) ([]redis.Cmder, error)
- func (cli *Client) Provide() interface{}
- func (cli *Client) PubSubChannels(pattern string) *redis.StringSliceCmd
- func (cli *Client) PubSubNumSub(channels ...string) *redis.StringIntMapCmd
- func (cli *Client) Publish(channel string, message interface{}) *redis.IntCmd
- func (cli *Client) Quit() *redis.StatusCmd
- func (cli *Client) RPop(key string) *redis.StringCmd
- func (cli *Client) RPopCount(key string, count int) *redis.StringSliceCmd
- func (cli *Client) RPopLPush(source, destination string) *redis.StringCmd
- func (cli *Client) RPush(key string, values ...interface{}) *redis.IntCmd
- func (cli *Client) RPushX(key string, values ...interface{}) *redis.IntCmd
- func (cli *Client) Rename(key, newkey string) *redis.StatusCmd
- func (cli *Client) RenameNX(key, newkey string) *redis.BoolCmd
- func (cli *Client) Restore(key string, ttl time.Duration, value string) *redis.StatusCmd
- func (cli *Client) RestoreReplace(key string, ttl time.Duration, value string) *redis.StatusCmd
- func (cli *Client) SAdd(key string, members ...interface{}) *redis.IntCmd
- func (cli *Client) SCard(key string) *redis.IntCmd
- func (cli *Client) SDiff(keys ...string) *redis.StringSliceCmd
- func (cli *Client) SDiffStore(destination string, keys ...string) *redis.IntCmd
- func (cli *Client) SInter(keys ...string) *redis.StringSliceCmd
- func (cli *Client) SInterStore(destination string, keys ...string) *redis.IntCmd
- func (cli *Client) SIsMember(key string, member interface{}) *redis.BoolCmd
- func (cli *Client) SMIsMember(key string, members ...interface{}) *redis.BoolSliceCmd
- func (cli *Client) SMembers(key string) *redis.StringSliceCmd
- func (cli *Client) SMembersMap(key string) *redis.StringStructMapCmd
- func (cli *Client) SMove(source, destination string, member interface{}) *redis.BoolCmd
- func (cli *Client) SPop(key string) *redis.StringCmd
- func (cli *Client) SPopN(key string, count int64) *redis.StringSliceCmd
- func (cli *Client) SRandMember(key string) *redis.StringCmd
- func (cli *Client) SRandMemberN(key string, count int64) *redis.StringSliceCmd
- func (cli *Client) SRem(key string, members ...interface{}) *redis.IntCmd
- func (cli *Client) SScan(key string, cursor uint64, match string, count int64) *redis.ScanCmd
- func (cli *Client) SUnion(keys ...string) *redis.StringSliceCmd
- func (cli *Client) SUnionStore(destination string, keys ...string) *redis.IntCmd
- func (cli *Client) Scan(cursor uint64, match string, count int64) *redis.ScanCmd
- func (cli *Client) ScanType(cursor uint64, match string, count int64, keyType string) *redis.ScanCmd
- func (cli *Client) ScriptExists(hashes ...string) *redis.BoolSliceCmd
- func (cli *Client) ScriptLoad(script string) *redis.StringCmd
- func (cli *Client) Set(key string, value interface{}, expiration time.Duration) *redis.StatusCmd
- func (cli *Client) SetArgs(key string, value interface{}, a redis.SetArgs) *redis.StatusCmd
- func (cli *Client) SetBit(key string, offset int64, value int) *redis.IntCmd
- func (cli *Client) SetEX(key string, value interface{}, expiration time.Duration) *redis.StatusCmd
- func (cli *Client) SetNX(key string, value interface{}, expiration time.Duration) *redis.BoolCmd
- func (cli *Client) SetRange(key string, offset int64, value string) *redis.IntCmd
- func (cli *Client) SetXX(key string, value interface{}, expiration time.Duration) *redis.BoolCmd
- func (cli *Client) SlaveOf(host, port string) *redis.StatusCmd
- func (cli *Client) Sort(key string, sort *redis.Sort) *redis.StringSliceCmd
- func (cli *Client) SortInterfaces(key string, sort *redis.Sort) *redis.SliceCmd
- func (cli *Client) SortStore(key, store string, sort *redis.Sort) *redis.IntCmd
- func (cli *Client) StrLen(key string) *redis.IntCmd
- func (cli *Client) TTL(key string) *redis.DurationCmd
- func (cli *Client) Touch(keys ...string) *redis.IntCmd
- func (cli *Client) TxPipelined(fn func(redis.Pipeliner) error) ([]redis.Cmder, error)
- func (cli *Client) Type(key string) *redis.StatusCmd
- func (cli *Client) Unlink(keys ...string) *redis.IntCmd
- func (cli *Client) XAck(stream, group string, ids ...string) *redis.IntCmd
- func (cli *Client) XAdd(a *redis.XAddArgs) *redis.StringCmd
- func (cli *Client) XAutoClaim(a *redis.XAutoClaimArgs) *redis.XAutoClaimCmd
- func (cli *Client) XAutoClaimJustID(a *redis.XAutoClaimArgs) *redis.XAutoClaimJustIDCmd
- func (cli *Client) XClaim(a *redis.XClaimArgs) *redis.XMessageSliceCmd
- func (cli *Client) XClaimJustID(a *redis.XClaimArgs) *redis.StringSliceCmd
- func (cli *Client) XDel(stream string, ids ...string) *redis.IntCmd
- func (cli *Client) XGroupCreate(stream, group, start string) *redis.StatusCmd
- func (cli *Client) XGroupCreateConsumer(stream, group, consumer string) *redis.IntCmd
- func (cli *Client) XGroupCreateMkStream(stream, group, start string) *redis.StatusCmd
- func (cli *Client) XGroupDelConsumer(stream, group, consumer string) *redis.IntCmd
- func (cli *Client) XGroupDestroy(stream, group string) *redis.IntCmd
- func (cli *Client) XGroupSetID(stream, group, start string) *redis.StatusCmd
- func (cli *Client) XInfoConsumers(key string, group string) *redis.XInfoConsumersCmd
- func (cli *Client) XInfoGroups(key string) *redis.XInfoGroupsCmd
- func (cli *Client) XInfoStream(key string) *redis.XInfoStreamCmd
- func (cli *Client) XInfoStreamFull(key string, count int) *redis.XInfoStreamFullCmd
- func (cli *Client) XLen(stream string) *redis.IntCmd
- func (cli *Client) XPending(stream, group string) *redis.XPendingCmd
- func (cli *Client) XPendingExt(a *redis.XPendingExtArgs) *redis.XPendingExtCmd
- func (cli *Client) XRange(stream, start, stop string) *redis.XMessageSliceCmd
- func (cli *Client) XRangeN(stream, start, stop string, count int64) *redis.XMessageSliceCmd
- func (cli *Client) XRead(a *redis.XReadArgs) *redis.XStreamSliceCmd
- func (cli *Client) XReadGroup(a *redis.XReadGroupArgs) *redis.XStreamSliceCmd
- func (cli *Client) XReadStreams(streams ...string) *redis.XStreamSliceCmd
- func (cli *Client) XRevRange(stream string, start, stop string) *redis.XMessageSliceCmd
- func (cli *Client) XRevRangeN(stream string, start, stop string, count int64) *redis.XMessageSliceCmd
- func (cli *Client) XTrim(key string, maxLen int64) *redis.IntCmd
- func (cli *Client) XTrimApprox(key string, maxLen int64) *redis.IntCmd
- func (cli *Client) XTrimMaxLen(key string, maxLen int64) *redis.IntCmd
- func (cli *Client) XTrimMaxLenApprox(key string, maxLen, limit int64) *redis.IntCmd
- func (cli *Client) XTrimMinID(key string, minID string) *redis.IntCmd
- func (cli *Client) XTrimMinIDApprox(key string, minID string, limit int64) *redis.IntCmd
- func (cli *Client) ZAdd(key string, members ...*redis.Z) *redis.IntCmd
- func (cli *Client) ZAddArgs(key string, args redis.ZAddArgs) *redis.IntCmd
- func (cli *Client) ZAddArgsIncr(key string, args redis.ZAddArgs) *redis.FloatCmd
- func (cli *Client) ZAddCh(key string, members ...*redis.Z) *redis.IntCmd
- func (cli *Client) ZAddNX(key string, members ...*redis.Z) *redis.IntCmd
- func (cli *Client) ZAddNXCh(key string, members ...*redis.Z) *redis.IntCmd
- func (cli *Client) ZAddXX(key string, members ...*redis.Z) *redis.IntCmd
- func (cli *Client) ZAddXXCh(key string, members ...*redis.Z) *redis.IntCmd
- func (cli *Client) ZCard(key string) *redis.IntCmd
- func (cli *Client) ZCount(key, min, max string) *redis.IntCmd
- func (cli *Client) ZDiff(keys ...string) *redis.StringSliceCmd
- func (cli *Client) ZDiffStore(destination string, keys ...string) *redis.IntCmd
- func (cli *Client) ZDiffWithScores(keys ...string) *redis.ZSliceCmd
- func (cli *Client) ZIncr(key string, member *redis.Z) *redis.FloatCmd
- func (cli *Client) ZIncrBy(key string, increment float64, member string) *redis.FloatCmd
- func (cli *Client) ZIncrNX(key string, member *redis.Z) *redis.FloatCmd
- func (cli *Client) ZIncrXX(key string, member *redis.Z) *redis.FloatCmd
- func (cli *Client) ZInter(store *redis.ZStore) *redis.StringSliceCmd
- func (cli *Client) ZInterStore(destination string, store *redis.ZStore) *redis.IntCmd
- func (cli *Client) ZInterWithScores(store *redis.ZStore) *redis.ZSliceCmd
- func (cli *Client) ZLexCount(key, min, max string) *redis.IntCmd
- func (cli *Client) ZMScore(key string, members ...string) *redis.FloatSliceCmd
- func (cli *Client) ZPopMax(key string, count ...int64) *redis.ZSliceCmd
- func (cli *Client) ZPopMin(key string, count ...int64) *redis.ZSliceCmd
- func (cli *Client) ZRandMember(key string, count int, withScores bool) *redis.StringSliceCmd
- func (cli *Client) ZRange(key string, start, stop int64) *redis.StringSliceCmd
- func (cli *Client) ZRangeArgs(z redis.ZRangeArgs) *redis.StringSliceCmd
- func (cli *Client) ZRangeArgsWithScores(z redis.ZRangeArgs) *redis.ZSliceCmd
- func (cli *Client) ZRangeByLex(key string, opt *redis.ZRangeBy) *redis.StringSliceCmd
- func (cli *Client) ZRangeByScore(key string, opt *redis.ZRangeBy) *redis.StringSliceCmd
- func (cli *Client) ZRangeByScoreWithScores(key string, opt *redis.ZRangeBy) *redis.ZSliceCmd
- func (cli *Client) ZRangeStore(dst string, z redis.ZRangeArgs) *redis.IntCmd
- func (cli *Client) ZRangeWithScores(key string, start, stop int64) *redis.ZSliceCmd
- func (cli *Client) ZRank(key, member string) *redis.IntCmd
- func (cli *Client) ZRem(key string, members ...interface{}) *redis.IntCmd
- func (cli *Client) ZRemRangeByLex(key, min, max string) *redis.IntCmd
- func (cli *Client) ZRemRangeByRank(key string, start, stop int64) *redis.IntCmd
- func (cli *Client) ZRemRangeByScore(key, min, max string) *redis.IntCmd
- func (cli *Client) ZRevRange(key string, start, stop int64) *redis.StringSliceCmd
- func (cli *Client) ZRevRangeByLex(key string, opt *redis.ZRangeBy) *redis.StringSliceCmd
- func (cli *Client) ZRevRangeByScore(key string, opt *redis.ZRangeBy) *redis.StringSliceCmd
- func (cli *Client) ZRevRangeByScoreWithScores(key string, opt *redis.ZRangeBy) *redis.ZSliceCmd
- func (cli *Client) ZRevRangeWithScores(key string, start, stop int64) *redis.ZSliceCmd
- func (cli *Client) ZRevRank(key, member string) *redis.IntCmd
- func (cli *Client) ZScan(key string, cursor uint64, match string, count int64) *redis.ScanCmd
- func (cli *Client) ZScore(key, member string) *redis.FloatCmd
- func (cli *Client) ZUnion(store redis.ZStore) *redis.StringSliceCmd
- func (cli *Client) ZUnionStore(dest string, store *redis.ZStore) *redis.IntCmd
- func (cli *Client) ZUnionWithScores(store redis.ZStore) *redis.ZSliceCmd
- type Conn
- type Option
- func WithDb(dbNum int) Option
- func WithDialTimeout(dial time.Duration) Option
- func WithHost(host string) Option
- func WithIdleTimeout(idle time.Duration) Option
- func WithMaxConnAge(maxConnAge time.Duration) Option
- func WithMinIdle(minIdle int) Option
- func WithPassword(password string) Option
- func WithPoolSize(poolSize int) Option
- func WithPoolTimeout(pool time.Duration) Option
- func WithPort(port int) Option
- func WithReadTimeout(read time.Duration) Option
- func WithWriteTimeout(write time.Duration) Option
- type Options
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct { *redis.Client // contains filtered or unexported fields }
func (*Client) BRPopLPush ¶
func (*Client) ClientGetName ¶
func (cli *Client) ClientGetName() *redis.StringCmd
func (*Client) ClientKill ¶
func (*Client) ClientKillByFilter ¶
func (*Client) ClientPause ¶
func (*Client) ClusterAddSlots ¶
func (*Client) ClusterAddSlotsRange ¶
func (*Client) ClusterCountFailureReports ¶
func (*Client) ClusterCountKeysInSlot ¶
func (*Client) ClusterDelSlots ¶
func (*Client) ClusterDelSlotsRange ¶
func (*Client) ClusterForget ¶
func (*Client) ClusterGetKeysInSlot ¶
func (*Client) ClusterKeySlot ¶
func (*Client) ClusterMeet ¶
func (*Client) ClusterReplicate ¶
func (*Client) ClusterSlaves ¶
func (*Client) DebugObject ¶
func (*Client) GeoRadiusByMember ¶
func (*Client) GeoRadiusByMemberStore ¶
func (*Client) GeoRadiusStore ¶
func (*Client) GeoSearchLocation ¶
func (*Client) GeoSearchStore ¶
func (*Client) HIncrByFloat ¶
func (*Client) HRandField ¶
func (*Client) IncrByFloat ¶
func (*Client) LInsertAfter ¶
func (*Client) LInsertBefore ¶
func (*Client) MemoryUsage ¶
func (*Client) ObjectEncoding ¶
func (*Client) ObjectIdleTime ¶
func (*Client) ObjectRefCount ¶
func (*Client) PubSubChannels ¶
func (*Client) PubSubNumSub ¶
func (*Client) RestoreReplace ¶
func (*Client) SDiffStore ¶
func (*Client) SInterStore ¶
func (*Client) SMIsMember ¶
func (*Client) SMembersMap ¶
func (*Client) SRandMember ¶
func (*Client) SRandMemberN ¶
func (*Client) SUnionStore ¶
func (*Client) ScriptExists ¶
func (*Client) ScriptLoad ¶
func (*Client) SortInterfaces ¶
func (*Client) TxPipelined ¶
func (*Client) XAutoClaim ¶
func (cli *Client) XAutoClaim(a *redis.XAutoClaimArgs) *redis.XAutoClaimCmd
func (*Client) XAutoClaimJustID ¶
func (cli *Client) XAutoClaimJustID(a *redis.XAutoClaimArgs) *redis.XAutoClaimJustIDCmd
func (*Client) XClaimJustID ¶
func (cli *Client) XClaimJustID(a *redis.XClaimArgs) *redis.StringSliceCmd
func (*Client) XGroupCreate ¶
func (*Client) XGroupCreateConsumer ¶
func (*Client) XGroupCreateMkStream ¶
func (*Client) XGroupDelConsumer ¶
func (*Client) XGroupDestroy ¶
func (*Client) XGroupSetID ¶
func (*Client) XInfoConsumers ¶
func (*Client) XInfoGroups ¶
func (*Client) XInfoStream ¶
func (*Client) XInfoStreamFull ¶
func (*Client) XPendingExt ¶
func (cli *Client) XPendingExt(a *redis.XPendingExtArgs) *redis.XPendingExtCmd
func (*Client) XReadGroup ¶
func (cli *Client) XReadGroup(a *redis.XReadGroupArgs) *redis.XStreamSliceCmd
func (*Client) XReadStreams ¶
func (*Client) XRevRangeN ¶
func (*Client) XTrimApprox ¶
func (*Client) XTrimMaxLen ¶
func (*Client) XTrimMaxLenApprox ¶
func (*Client) XTrimMinID ¶
func (*Client) XTrimMinIDApprox ¶
func (*Client) ZAddArgsIncr ¶
func (*Client) ZDiffStore ¶
func (*Client) ZDiffWithScores ¶
func (*Client) ZInterStore ¶
func (*Client) ZInterWithScores ¶
func (cli *Client) ZInterWithScores(store *redis.ZStore) *redis.ZSliceCmd
func (*Client) ZRandMember ¶
func (*Client) ZRangeArgs ¶
func (cli *Client) ZRangeArgs(z redis.ZRangeArgs) *redis.StringSliceCmd
func (*Client) ZRangeArgsWithScores ¶
func (cli *Client) ZRangeArgsWithScores(z redis.ZRangeArgs) *redis.ZSliceCmd
func (*Client) ZRangeByLex ¶
func (*Client) ZRangeByScore ¶
func (*Client) ZRangeByScoreWithScores ¶
func (*Client) ZRangeStore ¶
func (*Client) ZRangeWithScores ¶
func (*Client) ZRemRangeByLex ¶
func (*Client) ZRemRangeByRank ¶
func (*Client) ZRemRangeByScore ¶
func (*Client) ZRevRangeByLex ¶
func (*Client) ZRevRangeByScore ¶
func (*Client) ZRevRangeByScoreWithScores ¶
func (*Client) ZRevRangeWithScores ¶
func (*Client) ZUnionStore ¶
func (*Client) ZUnionWithScores ¶
func (cli *Client) ZUnionWithScores(store redis.ZStore) *redis.ZSliceCmd
type Conn ¶
type Conn interface { Pipeline() redis.Pipeliner Pipelined(fn func(redis.Pipeliner) error) ([]redis.Cmder, error) TxPipelined(fn func(redis.Pipeliner) error) ([]redis.Cmder, error) TxPipeline() redis.Pipeliner Command() *redis.CommandsInfoCmd ClientGetName() *redis.StringCmd Echo(message interface{}) *redis.StringCmd Ping() *redis.StatusCmd Quit() *redis.StatusCmd Del(keys ...string) *redis.IntCmd Unlink(keys ...string) *redis.IntCmd Dump(key string) *redis.StringCmd Exists(keys ...string) *redis.IntCmd Expire(key string, expiration time.Duration) *redis.BoolCmd ExpireAt(key string, tm time.Time) *redis.BoolCmd ExpireNX(key string, expiration time.Duration) *redis.BoolCmd ExpireXX(key string, expiration time.Duration) *redis.BoolCmd ExpireGT(key string, expiration time.Duration) *redis.BoolCmd ExpireLT(key string, expiration time.Duration) *redis.BoolCmd Keys(pattern string) *redis.StringSliceCmd Migrate(host, port, key string, db int, timeout time.Duration) *redis.StatusCmd Move(key string, db int) *redis.BoolCmd ObjectRefCount(key string) *redis.IntCmd ObjectEncoding(key string) *redis.StringCmd ObjectIdleTime(key string) *redis.DurationCmd Persist(key string) *redis.BoolCmd PExpire(key string, expiration time.Duration) *redis.BoolCmd PExpireAt(key string, tm time.Time) *redis.BoolCmd PTTL(key string) *redis.DurationCmd RandomKey(ctx context.Context) *redis.StringCmd Rename(key, newkey string) *redis.StatusCmd RenameNX(key, newkey string) *redis.BoolCmd Restore(key string, ttl time.Duration, value string) *redis.StatusCmd RestoreReplace(key string, ttl time.Duration, value string) *redis.StatusCmd Sort(key string, sort *redis.Sort) *redis.StringSliceCmd SortStore(key, store string, sort *redis.Sort) *redis.IntCmd SortInterfaces(key string, sort *redis.Sort) *redis.SliceCmd Touch(keys ...string) *redis.IntCmd TTL(key string) *redis.DurationCmd Type(key string) *redis.StatusCmd Append(key, value string) *redis.IntCmd Decr(key string) *redis.IntCmd DecrBy(key string, decrement int64) *redis.IntCmd Get(key string) *redis.StringCmd GetRange(key string, start, end int64) *redis.StringCmd GetSet(key string, value interface{}) *redis.StringCmd GetEx(key string, expiration time.Duration) *redis.StringCmd GetDel(key string) *redis.StringCmd Incr(key string) *redis.IntCmd IncrBy(key string, value int64) *redis.IntCmd IncrByFloat(key string, value float64) *redis.FloatCmd MGet(keys ...string) *redis.SliceCmd MSet(values ...interface{}) *redis.StatusCmd MSetNX(values ...interface{}) *redis.BoolCmd Set(key string, value interface{}, expiration time.Duration) *redis.StatusCmd SetArgs(key string, value interface{}, a redis.SetArgs) *redis.StatusCmd SetEX(key string, value interface{}, expiration time.Duration) *redis.StatusCmd SetNX(key string, value interface{}, expiration time.Duration) *redis.BoolCmd SetXX(key string, value interface{}, expiration time.Duration) *redis.BoolCmd SetRange(key string, offset int64, value string) *redis.IntCmd StrLen(key string) *redis.IntCmd Copy(sourceKey string, destKey string, db int, replace bool) *redis.IntCmd GetBit(key string, offset int64) *redis.IntCmd SetBit(key string, offset int64, value int) *redis.IntCmd BitCount(key string, bitCount *redis.BitCount) *redis.IntCmd BitOpAnd(destKey string, keys ...string) *redis.IntCmd BitOpOr(destKey string, keys ...string) *redis.IntCmd BitOpXor(destKey string, keys ...string) *redis.IntCmd BitOpNot(destKey string, key string) *redis.IntCmd BitPos(key string, bit int64, pos ...int64) *redis.IntCmd BitField(key string, args ...interface{}) *redis.IntSliceCmd Scan(cursor uint64, match string, count int64) *redis.ScanCmd ScanType(cursor uint64, match string, count int64, keyType string) *redis.ScanCmd SScan(key string, cursor uint64, match string, count int64) *redis.ScanCmd HScan(key string, cursor uint64, match string, count int64) *redis.ScanCmd ZScan(key string, cursor uint64, match string, count int64) *redis.ScanCmd HDel(key string, fields ...string) *redis.IntCmd HExists(key, field string) *redis.BoolCmd HGet(key, field string) *redis.StringCmd HGetAll(key string) *redis.StringStringMapCmd HIncrBy(key, field string, incr int64) *redis.IntCmd HIncrByFloat(key, field string, incr float64) *redis.FloatCmd HKeys(key string) *redis.StringSliceCmd HLen(key string) *redis.IntCmd HMGet(key string, fields ...string) *redis.SliceCmd HSet(key string, values ...interface{}) *redis.IntCmd HMSet(key string, values ...interface{}) *redis.BoolCmd HSetNX(key, field string, value interface{}) *redis.BoolCmd HVals(key string) *redis.StringSliceCmd HRandField(key string, count int, withValues bool) *redis.StringSliceCmd BLPop(timeout time.Duration, keys ...string) *redis.StringSliceCmd BRPop(timeout time.Duration, keys ...string) *redis.StringSliceCmd BRPopLPush(source, destination string, timeout time.Duration) *redis.StringCmd LIndex(key string, index int64) *redis.StringCmd LInsert(key, op string, pivot, value interface{}) *redis.IntCmd LInsertBefore(key string, pivot, value interface{}) *redis.IntCmd LInsertAfter(key string, pivot, value interface{}) *redis.IntCmd LLen(key string) *redis.IntCmd LPop(key string) *redis.StringCmd LPopCount(key string, count int) *redis.StringSliceCmd LPos(key string, value string, args redis.LPosArgs) *redis.IntCmd LPosCount(key string, value string, count int64, args redis.LPosArgs) *redis.IntSliceCmd LPush(key string, values ...interface{}) *redis.IntCmd LPushX(key string, values ...interface{}) *redis.IntCmd LRange(key string, start, stop int64) *redis.StringSliceCmd LRem(key string, count int64, value interface{}) *redis.IntCmd LSet(key string, index int64, value interface{}) *redis.StatusCmd LTrim(key string, start, stop int64) *redis.StatusCmd RPop(key string) *redis.StringCmd RPopCount(key string, count int) *redis.StringSliceCmd RPopLPush(source, destination string) *redis.StringCmd RPush(key string, values ...interface{}) *redis.IntCmd RPushX(key string, values ...interface{}) *redis.IntCmd LMove(source, destination, srcpos, destpos string) *redis.StringCmd BLMove(source, destination, srcpos, destpos string, timeout time.Duration) *redis.StringCmd SAdd(key string, members ...interface{}) *redis.IntCmd SCard(key string) *redis.IntCmd SDiff(keys ...string) *redis.StringSliceCmd SDiffStore(destination string, keys ...string) *redis.IntCmd SInter(keys ...string) *redis.StringSliceCmd SInterStore(destination string, keys ...string) *redis.IntCmd SIsMember(key string, member interface{}) *redis.BoolCmd SMIsMember(key string, members ...interface{}) *redis.BoolSliceCmd SMembers(key string) *redis.StringSliceCmd SMembersMap(key string) *redis.StringStructMapCmd SMove(source, destination string, member interface{}) *redis.BoolCmd SPop(key string) *redis.StringCmd SPopN(key string, count int64) *redis.StringSliceCmd SRandMember(key string) *redis.StringCmd SRandMemberN(key string, count int64) *redis.StringSliceCmd SRem(key string, members ...interface{}) *redis.IntCmd SUnion(keys ...string) *redis.StringSliceCmd SUnionStore(destination string, keys ...string) *redis.IntCmd XAdd(a *redis.XAddArgs) *redis.StringCmd XDel(stream string, ids ...string) *redis.IntCmd XLen(stream string) *redis.IntCmd XRange(stream, start, stop string) *redis.XMessageSliceCmd XRangeN(stream, start, stop string, count int64) *redis.XMessageSliceCmd XRevRange(stream string, start, stop string) *redis.XMessageSliceCmd XRevRangeN(stream string, start, stop string, count int64) *redis.XMessageSliceCmd XRead(a *redis.XReadArgs) *redis.XStreamSliceCmd XReadStreams(streams ...string) *redis.XStreamSliceCmd XGroupCreate(stream, group, start string) *redis.StatusCmd XGroupCreateMkStream(stream, group, start string) *redis.StatusCmd XGroupSetID(stream, group, start string) *redis.StatusCmd XGroupDestroy(stream, group string) *redis.IntCmd XGroupCreateConsumer(stream, group, consumer string) *redis.IntCmd XGroupDelConsumer(stream, group, consumer string) *redis.IntCmd XReadGroup(a *redis.XReadGroupArgs) *redis.XStreamSliceCmd XAck(stream, group string, ids ...string) *redis.IntCmd XPending(stream, group string) *redis.XPendingCmd XPendingExt(a *redis.XPendingExtArgs) *redis.XPendingExtCmd XClaim(a *redis.XClaimArgs) *redis.XMessageSliceCmd XClaimJustID(a *redis.XClaimArgs) *redis.StringSliceCmd XAutoClaim(a *redis.XAutoClaimArgs) *redis.XAutoClaimCmd XAutoClaimJustID(a *redis.XAutoClaimArgs) *redis.XAutoClaimJustIDCmd XTrim(key string, maxLen int64) *redis.IntCmd XTrimApprox(key string, maxLen int64) *redis.IntCmd XTrimMaxLen(key string, maxLen int64) *redis.IntCmd XTrimMaxLenApprox(key string, maxLen, limit int64) *redis.IntCmd XTrimMinID(key string, minID string) *redis.IntCmd XTrimMinIDApprox(key string, minID string, limit int64) *redis.IntCmd XInfoGroups(key string) *redis.XInfoGroupsCmd XInfoStream(key string) *redis.XInfoStreamCmd XInfoStreamFull(key string, count int) *redis.XInfoStreamFullCmd XInfoConsumers(key string, group string) *redis.XInfoConsumersCmd BZPopMax(timeout time.Duration, keys ...string) *redis.ZWithKeyCmd BZPopMin(timeout time.Duration, keys ...string) *redis.ZWithKeyCmd ZAdd(key string, members ...*redis.Z) *redis.IntCmd ZAddNX(key string, members ...*redis.Z) *redis.IntCmd ZAddXX(key string, members ...*redis.Z) *redis.IntCmd ZAddCh(key string, members ...*redis.Z) *redis.IntCmd ZAddNXCh(key string, members ...*redis.Z) *redis.IntCmd ZAddXXCh(key string, members ...*redis.Z) *redis.IntCmd ZAddArgs(key string, args redis.ZAddArgs) *redis.IntCmd ZAddArgsIncr(key string, args redis.ZAddArgs) *redis.FloatCmd ZIncr(key string, member *redis.Z) *redis.FloatCmd ZIncrNX(key string, member *redis.Z) *redis.FloatCmd ZIncrXX(key string, member *redis.Z) *redis.FloatCmd ZCard(key string) *redis.IntCmd ZCount(key, min, max string) *redis.IntCmd ZLexCount(key, min, max string) *redis.IntCmd ZIncrBy(key string, increment float64, member string) *redis.FloatCmd ZInter(store *redis.ZStore) *redis.StringSliceCmd ZInterWithScores(store *redis.ZStore) *redis.ZSliceCmd ZInterStore(destination string, store *redis.ZStore) *redis.IntCmd ZMScore(key string, members ...string) *redis.FloatSliceCmd ZPopMax(key string, count ...int64) *redis.ZSliceCmd ZPopMin(key string, count ...int64) *redis.ZSliceCmd ZRange(key string, start, stop int64) *redis.StringSliceCmd ZRangeWithScores(key string, start, stop int64) *redis.ZSliceCmd ZRangeByScore(key string, opt *redis.ZRangeBy) *redis.StringSliceCmd ZRangeByLex(key string, opt *redis.ZRangeBy) *redis.StringSliceCmd ZRangeByScoreWithScores(key string, opt *redis.ZRangeBy) *redis.ZSliceCmd ZRangeArgs(z redis.ZRangeArgs) *redis.StringSliceCmd ZRangeArgsWithScores(z redis.ZRangeArgs) *redis.ZSliceCmd ZRangeStore(dst string, z redis.ZRangeArgs) *redis.IntCmd ZRank(key, member string) *redis.IntCmd ZRem(key string, members ...interface{}) *redis.IntCmd ZRemRangeByRank(key string, start, stop int64) *redis.IntCmd ZRemRangeByScore(key, min, max string) *redis.IntCmd ZRemRangeByLex(key, min, max string) *redis.IntCmd ZRevRange(key string, start, stop int64) *redis.StringSliceCmd ZRevRangeWithScores(key string, start, stop int64) *redis.ZSliceCmd ZRevRangeByScore(key string, opt *redis.ZRangeBy) *redis.StringSliceCmd ZRevRangeByLex(key string, opt *redis.ZRangeBy) *redis.StringSliceCmd ZRevRangeByScoreWithScores(key string, opt *redis.ZRangeBy) *redis.ZSliceCmd ZRevRank(key, member string) *redis.IntCmd ZScore(key, member string) *redis.FloatCmd ZUnionStore(dest string, store *redis.ZStore) *redis.IntCmd ZUnion(store redis.ZStore) *redis.StringSliceCmd ZUnionWithScores(store redis.ZStore) *redis.ZSliceCmd ZRandMember(key string, count int, withScores bool) *redis.StringSliceCmd ZDiff(keys ...string) *redis.StringSliceCmd ZDiffWithScores(keys ...string) *redis.ZSliceCmd ZDiffStore(destination string, keys ...string) *redis.IntCmd PFAdd(key string, els ...interface{}) *redis.IntCmd PFCount(keys ...string) *redis.IntCmd PFMerge(dest string, keys ...string) *redis.StatusCmd BgRewriteAOF(ctx context.Context) *redis.StatusCmd BgSave(ctx context.Context) *redis.StatusCmd ClientKill(ipPort string) *redis.StatusCmd ClientKillByFilter(keys ...string) *redis.IntCmd ClientList(ctx context.Context) *redis.StringCmd ClientPause(dur time.Duration) *redis.BoolCmd ClientID(ctx context.Context) *redis.IntCmd ConfigGet(parameter string) *redis.SliceCmd ConfigResetStat(ctx context.Context) *redis.StatusCmd ConfigSet(parameter, value string) *redis.StatusCmd ConfigRewrite(ctx context.Context) *redis.StatusCmd DBSize(ctx context.Context) *redis.IntCmd FlushAll(ctx context.Context) *redis.StatusCmd FlushAllAsync(ctx context.Context) *redis.StatusCmd FlushDB(ctx context.Context) *redis.StatusCmd FlushDBAsync(ctx context.Context) *redis.StatusCmd Info(section ...string) *redis.StringCmd LastSave(ctx context.Context) *redis.IntCmd Save(ctx context.Context) *redis.StatusCmd Shutdown(ctx context.Context) *redis.StatusCmd ShutdownSave(ctx context.Context) *redis.StatusCmd ShutdownNoSave(ctx context.Context) *redis.StatusCmd SlaveOf(host, port string) *redis.StatusCmd Time(ctx context.Context) *redis.TimeCmd DebugObject(key string) *redis.StringCmd ReadOnly(ctx context.Context) *redis.StatusCmd ReadWrite(ctx context.Context) *redis.StatusCmd MemoryUsage(key string, samples ...int) *redis.IntCmd Eval(script string, keys []string, args ...interface{}) *redis.Cmd EvalSha(sha1 string, keys []string, args ...interface{}) *redis.Cmd ScriptExists(hashes ...string) *redis.BoolSliceCmd ScriptFlush(ctx context.Context) *redis.StatusCmd ScriptKill(ctx context.Context) *redis.StatusCmd ScriptLoad(script string) *redis.StringCmd Publish(channel string, message interface{}) *redis.IntCmd PubSubChannels(pattern string) *redis.StringSliceCmd PubSubNumSub(channels ...string) *redis.StringIntMapCmd PubSubNumPat(ctx context.Context) *redis.IntCmd ClusterSlots(ctx context.Context) *redis.ClusterSlotsCmd ClusterNodes(ctx context.Context) *redis.StringCmd ClusterMeet(host, port string) *redis.StatusCmd ClusterForget(nodeID string) *redis.StatusCmd ClusterReplicate(nodeID string) *redis.StatusCmd ClusterResetSoft(ctx context.Context) *redis.StatusCmd ClusterResetHard(ctx context.Context) *redis.StatusCmd ClusterInfo(ctx context.Context) *redis.StringCmd ClusterKeySlot(key string) *redis.IntCmd ClusterGetKeysInSlot(slot int, count int) *redis.StringSliceCmd ClusterCountFailureReports(nodeID string) *redis.IntCmd ClusterCountKeysInSlot(slot int) *redis.IntCmd ClusterDelSlots(slots ...int) *redis.StatusCmd ClusterDelSlotsRange(min, max int) *redis.StatusCmd ClusterSaveConfig(ctx context.Context) *redis.StatusCmd ClusterSlaves(nodeID string) *redis.StringSliceCmd ClusterFailover(ctx context.Context) *redis.StatusCmd ClusterAddSlots(slots ...int) *redis.StatusCmd ClusterAddSlotsRange(min, max int) *redis.StatusCmd GeoAdd(key string, geoLocation ...*redis.GeoLocation) *redis.IntCmd GeoPos(key string, members ...string) *redis.GeoPosCmd GeoRadius(key string, longitude, latitude float64, query *redis.GeoRadiusQuery) *redis.GeoLocationCmd GeoRadiusStore(key string, longitude, latitude float64, query *redis.GeoRadiusQuery) *redis.IntCmd GeoRadiusByMember(key, member string, query *redis.GeoRadiusQuery) *redis.GeoLocationCmd GeoRadiusByMemberStore(key, member string, query *redis.GeoRadiusQuery) *redis.IntCmd GeoSearch(key string, q *redis.GeoSearchQuery) *redis.StringSliceCmd GeoSearchLocation(key string, q *redis.GeoSearchLocationQuery) *redis.GeoSearchLocationCmd GeoSearchStore(key, store string, q *redis.GeoSearchStoreQuery) *redis.IntCmd GeoDist(key string, member1, member2, unit string) *redis.FloatCmd GeoHash(key string, members ...string) *redis.StringSliceCmd }
type Option ¶
type Option func(*Options)
func WithDialTimeout ¶
func WithIdleTimeout ¶
func WithMaxConnAge ¶
func WithMinIdle ¶
func WithPassword ¶
func WithPoolSize ¶
func WithPoolTimeout ¶
func WithReadTimeout ¶
func WithWriteTimeout ¶
Click to show internal directories.
Click to hide internal directories.