type github.com/redis/go-redis/v9.Pipeliner (interface)
Method Implmentations
ACLDryRun(ctx context.Context, username string, command ...interface{}) *StringCmd
(*Pipeline).cmdable.ACLDryRun
AuthACL(ctx context.Context, username, password string) *StatusCmd
(*Pipeline).statefulCmdable.AuthACL
BLMPop(ctx context.Context, timeout time.Duration, direction string, count int64, keys ...string) *KeyValuesCmd
(*Pipeline).cmdable.BLMPop
BLMove(ctx context.Context, source, destination, srcpos, destpos string, timeout time.Duration) *StringCmd
(*Pipeline).cmdable.BLMove
BLPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd
(*Pipeline).cmdable.BLPop
BRPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd
(*Pipeline).cmdable.BRPop
BRPopLPush(ctx context.Context, source, destination string, timeout time.Duration) *StringCmd
(*Pipeline).cmdable.BRPopLPush
BZMPop(ctx context.Context, timeout time.Duration, order string, count int64, keys ...string) *ZSliceWithKeyCmd
(*Pipeline).cmdable.BZMPop
BZPopMax(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd
(*Pipeline).cmdable.BZPopMax
BZPopMin(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd
(*Pipeline).cmdable.BZPopMin
BitField(ctx context.Context, key string, args ...interface{}) *IntSliceCmd
(*Pipeline).cmdable.BitField
BitPosSpan(ctx context.Context, key string, bit int8, start, end int64, span string) *IntCmd
(*Pipeline).cmdable.BitPosSpan
ClientKillByFilter(ctx context.Context, keys ...string) *IntCmd
(*Pipeline).cmdable.ClientKillByFilter
ClientUnblockWithError(ctx context.Context, id int64) *IntCmd
(*Pipeline).cmdable.ClientUnblockWithError
ClusterAddSlotsRange(ctx context.Context, min, max int) *StatusCmd
(*Pipeline).cmdable.ClusterAddSlotsRange
ClusterCountFailureReports(ctx context.Context, nodeID string) *IntCmd
(*Pipeline).cmdable.ClusterCountFailureReports
ClusterCountKeysInSlot(ctx context.Context, slot int) *IntCmd
(*Pipeline).cmdable.ClusterCountKeysInSlot
ClusterDelSlotsRange(ctx context.Context, min, max int) *StatusCmd
(*Pipeline).cmdable.ClusterDelSlotsRange
ClusterGetKeysInSlot(ctx context.Context, slot int, count int) *StringSliceCmd
(*Pipeline).cmdable.ClusterGetKeysInSlot
ClusterReplicate(ctx context.Context, nodeID string) *StatusCmd
(*Pipeline).cmdable.ClusterReplicate
CommandGetKeys(ctx context.Context, commands ...interface{}) *StringSliceCmd
(*Pipeline).cmdable.CommandGetKeys
CommandGetKeysAndFlags(ctx context.Context, commands ...interface{}) *KeyFlagsCmd
(*Pipeline).cmdable.CommandGetKeysAndFlags
Copy(ctx context.Context, sourceKey string, destKey string, db int, replace bool) *IntCmd
(*Pipeline).cmdable.Copy
Eval(ctx context.Context, script string, keys []string, args ...interface{}) *Cmd
(*Pipeline).cmdable.Eval
EvalRO(ctx context.Context, script string, keys []string, args ...interface{}) *Cmd
(*Pipeline).cmdable.EvalRO
EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *Cmd
(*Pipeline).cmdable.EvalSha
EvalShaRO(ctx context.Context, sha1 string, keys []string, args ...interface{}) *Cmd
(*Pipeline).cmdable.EvalShaRO
Expire(ctx context.Context, key string, expiration time.Duration) *BoolCmd
(*Pipeline).cmdable.Expire
ExpireGT(ctx context.Context, key string, expiration time.Duration) *BoolCmd
(*Pipeline).cmdable.ExpireGT
ExpireLT(ctx context.Context, key string, expiration time.Duration) *BoolCmd
(*Pipeline).cmdable.ExpireLT
ExpireNX(ctx context.Context, key string, expiration time.Duration) *BoolCmd
(*Pipeline).cmdable.ExpireNX
ExpireXX(ctx context.Context, key string, expiration time.Duration) *BoolCmd
(*Pipeline).cmdable.ExpireXX
FCall(ctx context.Context, function string, keys []string, args ...interface{}) *Cmd
(*Pipeline).cmdable.FCall
FCallRo(ctx context.Context, function string, keys []string, args ...interface{}) *Cmd
(*Pipeline).cmdable.FCallRo
FunctionList(ctx context.Context, q FunctionListQuery) *FunctionListCmd
(*Pipeline).cmdable.FunctionList
FunctionLoadReplace(ctx context.Context, code string) *StringCmd
(*Pipeline).cmdable.FunctionLoadReplace
GeoAdd(ctx context.Context, key string, geoLocation ...*GeoLocation) *IntCmd
(*Pipeline).cmdable.GeoAdd
GeoDist(ctx context.Context, key string, member1, member2, unit string) *FloatCmd
(*Pipeline).cmdable.GeoDist
GeoHash(ctx context.Context, key string, members ...string) *StringSliceCmd
(*Pipeline).cmdable.GeoHash
GeoRadius(ctx context.Context, key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd
(*Pipeline).cmdable.GeoRadius
GeoRadiusByMember(ctx context.Context, key, member string, query *GeoRadiusQuery) *GeoLocationCmd
(*Pipeline).cmdable.GeoRadiusByMember
GeoRadiusByMemberStore(ctx context.Context, key, member string, query *GeoRadiusQuery) *IntCmd
(*Pipeline).cmdable.GeoRadiusByMemberStore
GeoRadiusStore(ctx context.Context, key string, longitude, latitude float64, query *GeoRadiusQuery) *IntCmd
(*Pipeline).cmdable.GeoRadiusStore
GeoSearch(ctx context.Context, key string, q *GeoSearchQuery) *StringSliceCmd
(*Pipeline).cmdable.GeoSearch
GeoSearchLocation(ctx context.Context, key string, q *GeoSearchLocationQuery) *GeoSearchLocationCmd
(*Pipeline).cmdable.GeoSearchLocation
GeoSearchStore(ctx context.Context, key, store string, q *GeoSearchStoreQuery) *IntCmd
(*Pipeline).cmdable.GeoSearchStore
GetEx(ctx context.Context, key string, expiration time.Duration) *StringCmd
(*Pipeline).cmdable.GetEx
HIncrByFloat(ctx context.Context, key, field string, incr float64) *FloatCmd
(*Pipeline).cmdable.HIncrByFloat
HRandField(ctx context.Context, key string, count int) *StringSliceCmd
(*Pipeline).cmdable.HRandField
HRandFieldWithValues(ctx context.Context, key string, count int) *KeyValueSliceCmd
(*Pipeline).cmdable.HRandFieldWithValues
HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd
(*Pipeline).cmdable.HScan
HSetNX(ctx context.Context, key, field string, value interface{}) *BoolCmd
(*Pipeline).cmdable.HSetNX
Hello(ctx context.Context, ver int, username, password, clientName string) *MapStringInterfaceCmd
(*Pipeline).statefulCmdable.Hello
IncrByFloat(ctx context.Context, key string, value float64) *FloatCmd
(*Pipeline).cmdable.IncrByFloat
LInsert(ctx context.Context, key, op string, pivot, value interface{}) *IntCmd
(*Pipeline).cmdable.LInsert
LInsertAfter(ctx context.Context, key string, pivot, value interface{}) *IntCmd
(*Pipeline).cmdable.LInsertAfter
LInsertBefore(ctx context.Context, key string, pivot, value interface{}) *IntCmd
(*Pipeline).cmdable.LInsertBefore
LMPop(ctx context.Context, direction string, count int64, keys ...string) *KeyValuesCmd
(*Pipeline).cmdable.LMPop
LMove(ctx context.Context, source, destination, srcpos, destpos string) *StringCmd
(*Pipeline).cmdable.LMove
LPosCount(ctx context.Context, key string, value string, count int64, args LPosArgs) *IntSliceCmd
(*Pipeline).cmdable.LPosCount
LRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd
(*Pipeline).cmdable.LRange
LRem(ctx context.Context, key string, count int64, value interface{}) *IntCmd
(*Pipeline).cmdable.LRem
LSet(ctx context.Context, key string, index int64, value interface{}) *StatusCmd
(*Pipeline).cmdable.LSet
MemoryUsage(ctx context.Context, key string, samples ...int) *IntCmd
(*Pipeline).cmdable.MemoryUsage
Migrate(ctx context.Context, host, port, key string, db int, timeout time.Duration) *StatusCmd
(*Pipeline).cmdable.Migrate
PExpire(ctx context.Context, key string, expiration time.Duration) *BoolCmd
(*Pipeline).cmdable.PExpire
PubSubChannels(ctx context.Context, pattern string) *StringSliceCmd
(*Pipeline).cmdable.PubSubChannels
PubSubNumSub(ctx context.Context, channels ...string) *MapStringIntCmd
(*Pipeline).cmdable.PubSubNumSub
PubSubShardChannels(ctx context.Context, pattern string) *StringSliceCmd
(*Pipeline).cmdable.PubSubShardChannels
PubSubShardNumSub(ctx context.Context, channels ...string) *MapStringIntCmd
(*Pipeline).cmdable.PubSubShardNumSub
Publish(ctx context.Context, channel string, message interface{}) *IntCmd
(*Pipeline).cmdable.Publish
Restore(ctx context.Context, key string, ttl time.Duration, value string) *StatusCmd
(*Pipeline).cmdable.Restore
RestoreReplace(ctx context.Context, key string, ttl time.Duration, value string) *StatusCmd
(*Pipeline).cmdable.RestoreReplace
SDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd
(*Pipeline).cmdable.SDiffStore
SInterStore(ctx context.Context, destination string, keys ...string) *IntCmd
(*Pipeline).cmdable.SInterStore
SIsMember(ctx context.Context, key string, member interface{}) *BoolCmd
(*Pipeline).cmdable.SIsMember
SMIsMember(ctx context.Context, key string, members ...interface{}) *BoolSliceCmd
(*Pipeline).cmdable.SMIsMember
SMove(ctx context.Context, source, destination string, member interface{}) *BoolCmd
(*Pipeline).cmdable.SMove
SPublish(ctx context.Context, channel string, message interface{}) *IntCmd
(*Pipeline).cmdable.SPublish
SRandMemberN(ctx context.Context, key string, count int64) *StringSliceCmd
(*Pipeline).cmdable.SRandMemberN
SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd
(*Pipeline).cmdable.SScan
SUnionStore(ctx context.Context, destination string, keys ...string) *IntCmd
(*Pipeline).cmdable.SUnionStore
Scan(ctx context.Context, cursor uint64, match string, count int64) *ScanCmd
(*Pipeline).cmdable.Scan
ScanType(ctx context.Context, cursor uint64, match string, count int64, keyType string) *ScanCmd
(*Pipeline).cmdable.ScanType
Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd
(*Pipeline).cmdable.Set
SetArgs(ctx context.Context, key string, value interface{}, a SetArgs) *StatusCmd
(*Pipeline).cmdable.SetArgs
SetEx(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd
(*Pipeline).cmdable.SetEx
SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd
(*Pipeline).cmdable.SetNX
SetRange(ctx context.Context, key string, offset int64, value string) *IntCmd
(*Pipeline).cmdable.SetRange
SetXX(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd
(*Pipeline).cmdable.SetXX
SortInterfaces(ctx context.Context, key string, sort *Sort) *SliceCmd
(*Pipeline).cmdable.SortInterfaces
XAutoClaimJustID(ctx context.Context, a *XAutoClaimArgs) *XAutoClaimJustIDCmd
(*Pipeline).cmdable.XAutoClaimJustID
XGroupCreate(ctx context.Context, stream, group, start string) *StatusCmd
(*Pipeline).cmdable.XGroupCreate
XGroupCreateConsumer(ctx context.Context, stream, group, consumer string) *IntCmd
(*Pipeline).cmdable.XGroupCreateConsumer
XGroupCreateMkStream(ctx context.Context, stream, group, start string) *StatusCmd
(*Pipeline).cmdable.XGroupCreateMkStream
XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *IntCmd
(*Pipeline).cmdable.XGroupDelConsumer
XGroupSetID(ctx context.Context, stream, group, start string) *StatusCmd
(*Pipeline).cmdable.XGroupSetID
XInfoConsumers(ctx context.Context, key string, group string) *XInfoConsumersCmd
(*Pipeline).cmdable.XInfoConsumers
XInfoStreamFull(ctx context.Context, key string, count int) *XInfoStreamFullCmd
(*Pipeline).cmdable.XInfoStreamFull
XPendingExt(ctx context.Context, a *XPendingExtArgs) *XPendingExtCmd
(*Pipeline).cmdable.XPendingExt
XRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd
(*Pipeline).cmdable.XRange
XRangeN(ctx context.Context, stream, start, stop string, count int64) *XMessageSliceCmd
(*Pipeline).cmdable.XRangeN
XReadStreams(ctx context.Context, streams ...string) *XStreamSliceCmd
(*Pipeline).cmdable.XReadStreams
XRevRange(ctx context.Context, stream string, start, stop string) *XMessageSliceCmd
(*Pipeline).cmdable.XRevRange
XRevRangeN(ctx context.Context, stream string, start, stop string, count int64) *XMessageSliceCmd
(*Pipeline).cmdable.XRevRangeN
XTrimMaxLenApprox(ctx context.Context, key string, maxLen, limit int64) *IntCmd
(*Pipeline).cmdable.XTrimMaxLenApprox
XTrimMinIDApprox(ctx context.Context, key string, minID string, limit int64) *IntCmd
(*Pipeline).cmdable.XTrimMinIDApprox
ZAddArgsIncr(ctx context.Context, key string, args ZAddArgs) *FloatCmd
(*Pipeline).cmdable.ZAddArgsIncr
ZDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd
(*Pipeline).cmdable.ZDiffStore
ZIncrBy(ctx context.Context, key string, increment float64, member string) *FloatCmd
(*Pipeline).cmdable.ZIncrBy
ZInterStore(ctx context.Context, destination string, store *ZStore) *IntCmd
(*Pipeline).cmdable.ZInterStore
ZInterWithScores(ctx context.Context, store *ZStore) *ZSliceCmd
(*Pipeline).cmdable.ZInterWithScores
ZMPop(ctx context.Context, order string, count int64, keys ...string) *ZSliceWithKeyCmd
(*Pipeline).cmdable.ZMPop
ZMScore(ctx context.Context, key string, members ...string) *FloatSliceCmd
(*Pipeline).cmdable.ZMScore
ZRandMember(ctx context.Context, key string, count int) *StringSliceCmd
(*Pipeline).cmdable.ZRandMember
ZRandMemberWithScores(ctx context.Context, key string, count int) *ZSliceCmd
(*Pipeline).cmdable.ZRandMemberWithScores
ZRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd
(*Pipeline).cmdable.ZRange
ZRangeArgsWithScores(ctx context.Context, z ZRangeArgs) *ZSliceCmd
(*Pipeline).cmdable.ZRangeArgsWithScores
ZRangeByLex(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd
(*Pipeline).cmdable.ZRangeByLex
ZRangeByScore(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd
(*Pipeline).cmdable.ZRangeByScore
ZRangeByScoreWithScores(ctx context.Context, key string, opt *ZRangeBy) *ZSliceCmd
(*Pipeline).cmdable.ZRangeByScoreWithScores
ZRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd
(*Pipeline).cmdable.ZRangeWithScores
ZRemRangeByLex(ctx context.Context, key, min, max string) *IntCmd
(*Pipeline).cmdable.ZRemRangeByLex
ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *IntCmd
(*Pipeline).cmdable.ZRemRangeByRank
ZRemRangeByScore(ctx context.Context, key, min, max string) *IntCmd
(*Pipeline).cmdable.ZRemRangeByScore
ZRevRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd
(*Pipeline).cmdable.ZRevRange
ZRevRangeByLex(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd
(*Pipeline).cmdable.ZRevRangeByLex
ZRevRangeByScore(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd
(*Pipeline).cmdable.ZRevRangeByScore
ZRevRangeByScoreWithScores(ctx context.Context, key string, opt *ZRangeBy) *ZSliceCmd
(*Pipeline).cmdable.ZRevRangeByScoreWithScores
ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd
(*Pipeline).cmdable.ZRevRangeWithScores
ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd
(*Pipeline).cmdable.ZScan
ZUnionStore(ctx context.Context, dest string, store *ZStore) *IntCmd
(*Pipeline).cmdable.ZUnionStore
![]() |
The pages are generated with Golds v0.8.2. (GOOS=linux GOARCH=amd64) Golds is a Go 101 project developed by Tapir Liu. PR and bug reports are welcome and can be submitted to the issue list. Please follow @zigo_101 (reachable from the left QR code) to get the latest news of Golds. |