Documentation ¶
Index ¶
- type Append
- type BLPop
- type BRPop
- type BRPopLPush
- type BZPopMax
- type BZPopMin
- type BitCount
- type BitField
- type BitOpAnd
- type BitOpNot
- type BitOpOr
- type BitOpXor
- type BitPos
- type ClientKill
- type ClientKillByFilter
- type ClientPause
- type ClientUnblock
- type ClientUnblockWithError
- type ClusterAddSlots
- type ClusterAddSlotsRange
- type ClusterCountFailureReports
- type ClusterCountKeysInSlot
- type ClusterDelSlots
- type ClusterDelSlotsRange
- type ClusterForget
- type ClusterGetKeysInSlot
- type ClusterKeySlot
- type ClusterMeet
- type ClusterReplicate
- type ClusterSlaves
- type Command
- type Config
- type ConfigGet
- type ConfigSet
- type DebugObject
- type Decr
- type DecrBy
- type Del
- type Dump
- type Echo
- type Exists
- type Expire
- type ExpireAt
- type GeoAdd
- type GeoDist
- type GeoHash
- type GeoPos
- type GeoRadius
- type GeoRadiusByMember
- type GeoRadiusByMemberStore
- type GeoRadiusStore
- type Get
- type GetBit
- type GetRange
- type GetSet
- type HDel
- type HExists
- type HGet
- type HGetAll
- type HIncrBy
- type HIncrByFloat
- type HKeys
- type HLen
- type HMGet
- type HScan
- type HVals
- type Incr
- type IncrBy
- type IncrByFloat
- type Info
- type Keys
- type LIndex
- type LLen
- type LPop
- type LRange
- type LTrim
- type MGet
- type MemoryUsage
- type Migrate
- type Move
- type ObjectEncoding
- type ObjectIdleTime
- type ObjectRefCount
- type PExpire
- type PExpireAt
- type PFCount
- type PFMerge
- type PTTL
- type Persist
- type PubSubChannels
- type PubSubNumSub
- type Publish
- type RPop
- type RPopLPush
- type Rename
- type RenameNX
- type Restore
- type RestoreReplace
- type SCard
- type SDiff
- type SDiffStore
- type SInter
- type SInterStore
- type SMembers
- type SMembersMap
- type SPop
- type SPopN
- type SRandMember
- type SRandMemberN
- type SRem
- type SScan
- type SUnion
- type SUnionStore
- type Scan
- type ScriptExists
- type Set
- type SetBit
- type SetRange
- type SlaveOf
- type Sort
- type SortInterfaces
- type SortStore
- type StrLen
- type TTL
- type Touch
- type Type
- type Unlink
- type Wait
- type XAck
- type XAdd
- type XClaim
- type XClaimJustID
- type XDel
- type XGroupCreate
- type XGroupCreateMkStream
- type XGroupDelConsumer
- type XGroupDestroy
- type XGroupSetID
- type XInfoGroups
- type XLen
- type XPending
- type XPendingExt
- type XRange
- type XRangeN
- type XRead
- type XReadGroup
- type XReadStreams
- type XRevRange
- type XRevRangeN
- type XTrim
- type XTrimApprox
- type ZAdd
- type ZAddCh
- type ZAddNX
- type ZAddNXCh
- type ZAddXX
- type ZAddXXCh
- type ZCard
- type ZCount
- type ZIncr
- type ZIncrBy
- type ZIncrNX
- type ZIncrXX
- type ZInterStore
- type ZLexCount
- type ZPopMax
- type ZPopMin
- type ZRange
- type ZRangeByLex
- type ZRangeByScore
- type ZRangeByScoreWithScores
- type ZRangeWithScores
- type ZRank
- type ZRem
- type ZRemRangeByLex
- type ZRemRangeByRank
- type ZRemRangeByScore
- type ZRevRange
- type ZRevRangeByLex
- type ZRevRangeByScore
- type ZRevRangeByScoreWithScores
- type ZRevRangeWithScores
- type ZRevRank
- type ZScan
- type ZScore
- type ZUnionStore
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BRPopLPush ¶
type BRPopLPush struct { Source string `yaml:"source"` Dest string `yaml:"dest"` Timeout time.Duration `yaml:"timeout"` }
BRPopLPush ...
type ClientKillByFilter ¶
type ClientKillByFilter struct {
Keys []string `yaml:"keys"`
}
ClientKillByFilter ...
type ClientUnblockWithError ¶
type ClientUnblockWithError struct {
ID int64 `yaml:"id"`
}
ClientUnblockWithError ...
type ClusterAddSlots ¶
type ClusterAddSlots struct {
Slots []int `yaml:"slots"`
}
ClusterAddSlots ...
type ClusterAddSlotsRange ¶
ClusterAddSlotsRange ...
type ClusterCountFailureReports ¶
type ClusterCountFailureReports struct {
NodeID string `yaml:"nodeID"`
}
ClusterCountFailureReports ...
type ClusterCountKeysInSlot ¶
type ClusterCountKeysInSlot struct {
Slot int `yaml:"slot"`
}
ClusterCountKeysInSlot ...
type ClusterDelSlots ¶
type ClusterDelSlots struct {
Slots []int `yaml:"slots"`
}
ClusterDelSlots ...
type ClusterDelSlotsRange ¶
ClusterDelSlotsRange ...
type ClusterGetKeysInSlot ¶
ClusterGetKeysInSlot ...
type ClusterMeet ¶
ClusterMeet ...
type ClusterReplicate ¶
type ClusterReplicate struct {
NodeID string `yaml:"nodeID"`
}
ClusterReplicate ...
type Command ¶
type Command struct { Append *Append `yaml:"append,omitempty"` BLPop *BLPop `yaml:"blPop,omitempty"` BRPop *BRPop `yaml:"brPop,omitempty"` BRPopLPush *BRPopLPush `yaml:"brPopLPush,omitempty"` BZPopMax *BZPopMax `yaml:"bzPopMax,omitempty"` BZPopMin *BZPopMin `yaml:"bzPopMin,omitempty"` BgRewriteAOF *bool `yaml:"bgRewriteAof,omitempty"` BgSave *bool `yaml:"bgSave,omitempty"` BitCount *BitCount `yaml:"bitCount,omitempty"` BitField *BitField `yaml:"bitField,omitempty"` BitOpAnd *BitOpAnd `yaml:"bitOpAnd,omitempty"` BitOpNot *BitOpNot `yaml:"bitOpNot,omitempty"` BitOpOr *BitOpOr `yaml:"bitOpOr,omitempty"` BitOpXor *BitOpXor `yaml:"bitOpXor,omitempty"` BitPos *BitPos `yaml:"bitPos,omitempty,omitempty"` ClientGetName *bool `yaml:"clientGetName,omitempty"` ClientID *bool `yaml:"clientId,omitempty"` ClientKill *ClientKill `yaml:"clientKill,omitempty"` ClientKillByFilter *ClientKillByFilter `yaml:"clientKillByFilter,omitempty"` ClientList *bool `yaml:"clientList,omitempty"` ClientPause *ClientPause `yaml:"clientPause,omitempty"` ClientUnblock *ClientUnblock `yaml:"clientUnblock,omitempty"` ClientUnblockWithError *ClientUnblockWithError `yaml:"clientUnblockWithError"` Close *bool `yaml:"close,omitempty"` ClusterAddSlots *ClusterAddSlots `yaml:"clusterAddSlots,omitempty"` ClusterAddSlotsRange *ClusterAddSlotsRange `yaml:"clusterAddSlotsRange,omitempty"` ClusterCountFailureReports *ClusterCountFailureReports `yaml:"clusterCountFailureReports,omitempty"` ClusterCountKeysInSlot *ClusterCountKeysInSlot `yaml:"clusterCountKeysInSlot,omitempty"` ClusterDelSlots *ClusterDelSlots `yaml:"clusterDelSlots,omitempty"` ClusterDelSlotsRange *ClusterDelSlotsRange `yaml:"clusterDelSlotsRange,omitempty"` ClusterFailover *bool `yaml:"clusterFailover,omitempty"` ClusterForget *ClusterForget `yaml:"clusterForget,omitempty"` ClusterGetKeysInSlot *ClusterGetKeysInSlot `yaml:"clusterGetKeysInSlot,omitempty"` ClusterInfo *bool `yaml:"clusterInfo,omitempty"` ClusterKeySlot *ClusterKeySlot `yaml:"clusterKeySlot,omitempty"` ClusterMeet *ClusterMeet `yaml:"clusterMeet,omitempty"` ClusterNodes *bool `yaml:"clusterNodes,omitempty"` ClusterReplicate *ClusterReplicate `yaml:"clusterReplicate,omitempty"` ClusterResetHard *bool `yaml:"clusterResetHard,omitempty"` ClusterResetSoft *bool `yaml:"clusterResetSoft,omitempty"` ClusterSaveConfig *bool `yaml:"clusterSaveConfig,omitempty"` ClusterSlaves *ClusterSlaves `yaml:"clusterSlaves,omitempty"` ClusterSlots *bool `yaml:"clusterSlots,omitempty"` Command *bool `yaml:"command,omitempty"` ConfigGet *ConfigGet `yaml:"configGet,omitempty"` ConfigResetStat *bool `yaml:"configResetStat,omitempty"` ConfigRewrite *bool `yaml:"configRewrite,omitempty"` ConfigSet *ConfigSet `yaml:"configSet,omitempty"` DBSize *bool `yaml:"dbSize,omitempty"` DebugObject *DebugObject `yaml:"debugObject,omitempty"` Decr *Decr `yaml:"decr,omitempty"` DecrBy *DecrBy `yaml:"decrBy,omitempty"` Del *Del `yaml:"del,omitempty"` Dump *Dump `yaml:"dump,omitempty"` Echo *Echo `yaml:"echo,omitempty"` Exists *Exists `yaml:"exists,omitempty"` Expire *Expire `yaml:"expire,omitempty"` ExpireAt *ExpireAt `yaml:"expireAt,omitempty"` FlushAll *bool `yaml:"flushAll,omitempty"` FlushAllAsync *bool `yaml:"flushAllAsync,omitempty"` FlushDB *bool `yaml:"flushDB,omitempty"` FlushDBAsync *bool `yaml:"flushDBAsync,omitempty"` GeoAdd *GeoAdd `yaml:"geoAdd,omitempty"` LastSave *bool `yaml:"lastSave,omitempty"` GeoDist *GeoDist `yaml:"geoDist,omitempty"` GeoHash *GeoHash `yaml:"geoHash,omitempty"` GeoPos *GeoPos `yaml:"geoPos,omitempty"` GeoRadius *GeoRadius `yaml:"geoRadius,omitempty"` GeoRadiusByMember *GeoRadiusByMember `yaml:"geoRadiusByMember,omitempty"` GeoRadiusByMemberStore *GeoRadiusByMemberStore `yaml:"geoRadiusByMemberStore,omitempty"` GeoRadiusStore *GeoRadiusStore `yaml:"geoRadiusStore,omitempty"` Get *Get `yaml:"get,omitempty"` GetBit *GetBit `yaml:"getBit,omitempty"` GetRange *GetRange `yaml:"getRange,omitempty"` GetSet *GetSet `yaml:"getSet,omitempty"` HDel *HDel `yaml:"hDel,omitempty"` HExists *HExists `yaml:"hExists,omitempty"` HGet *HGet `yaml:"hGet,omitempty"` HGetAll *HGetAll `yaml:"hGetAll,omitempty"` HIncrBy *HIncrBy `yaml:"hIncrBy,omitempty"` HIncrByFloat *HIncrByFloat `yaml:"hIncrByFloat,omitempty"` HKeys *HKeys `yaml:"hKeys,omitempty"` HLen *HLen `yaml:"hLen,omitempty"` HMGet *HMGet `yaml:"hmGet,omitempty"` HScan *HScan `yaml:"hScan,omitempty"` HVals *HVals `yaml:"hVals,omitempty"` Incr *Incr `yaml:"incr,omitempty"` IncrBy *IncrBy `yaml:"incrBy,omitempty"` IncrByFloat *IncrByFloat `yaml:"incrByFloat,omitempty"` Info *Info `yaml:"info,omitempty"` Keys *Keys `yaml:"keys,omitempty"` LIndex *LIndex `yaml:"lIndex,omitempty"` LLen *LLen `yaml:"lLen,omitempty"` LPop *LPop `yaml:"lPop,omitempty"` LRange *LRange `yaml:"lRange,omitempty"` LTrim *LTrim `yaml:"lTrim,omitempty"` MGet *MGet `yaml:"mGet,omitempty"` MemoryUsage *MemoryUsage `yaml:"memoryUsage,omitempty"` Migrate *Migrate `yaml:"migrate,omitempty"` Move *Move `yaml:"move,omitempty"` ObjectEncoding *ObjectEncoding `yaml:"objectEncoding,omitempty"` ObjectIdleTime *ObjectIdleTime `yaml:"objectIdleTime,omitempty"` ObjectRefCount *ObjectRefCount `yaml:"objectRefCount,omitempty"` PExpire *PExpire `yaml:"pExpire,omitempty"` PExpireAt *PExpireAt `yaml:"pExpireAt,omitempty"` PFCount *PFCount `yaml:"pfCount,omitempty"` PFMerge *PFMerge `yaml:"pfMerge,omitempty"` PTTL *PTTL `yaml:"pttl,omitempty"` Persist *Persist `yaml:"persist,omitempty"` Ping *bool `yaml:"ping,omitempty"` PubSubChannels *PubSubChannels `yaml:"pubSubChannels,omitempty"` PubSubNumPat *bool `yaml:"pubSubNumPat,omitempty"` PubSubNumSub *PubSubNumSub `yaml:"pubSubNumSub,omitempty"` Publish *Publish `yaml:"publish,omitempty"` Quit *bool `yaml:"quit,omitempty"` RPop *RPop `yaml:"rPop,omitempty"` RPopLPush *RPopLPush `yaml:"rPopLPush,omitempty"` RandomKey *bool `yaml:"randomKey,omitempty"` ReadOnly *bool `yaml:"readOnly,omitempty"` ReadWrite *bool `yaml:"readWrite,omitempty"` Rename *Rename `yaml:"rename,omitempty"` RenameNX *RenameNX `yaml:"renameNX,omitempty"` Restore *Restore `yaml:"restore,omitempty"` RestoreReplace *RestoreReplace `yaml:"restoreReplace,omitempty"` SCard *SCard `yaml:"sCard,omitempty"` SDiff *SDiff `yaml:"sDiff,omitempty"` SDiffStore *SDiffStore `yaml:"sDiffStore,omitempty"` SInter *SInter `yaml:"sInter,omitempty"` SInterStore *SInterStore `yaml:"sInterStore,omitempty"` SMembers *SMembers `yaml:"sMembers,omitempty"` SMembersMap *SMembersMap `yaml:"sMembersMap,omitempty"` SPop *SPop `yaml:"sPop,omitempty"` SPopN *SPopN `yaml:"sPopN,omitempty"` SRandMember *SRandMember `yaml:"sRandMember,omitempty"` SRandMemberN *SRandMemberN `yaml:"sRandMemberN,omitempty"` SRem *SRem `yaml:"sRem,omitempty"` SScan *SScan `yaml:"sScan,omitempty"` SUnion *SUnion `yaml:"sUnion,omitempty"` SUnionStore *SUnionStore `yaml:"sUnionStore,omitempty"` Save *bool `yaml:"save,omitempty"` Scan *Scan `yaml:"scan,omitempty"` ScriptExists *ScriptExists `yaml:"scriptExists,omitempty"` ScriptFlush *bool `yaml:"scriptFlush,omitempty"` ScriptKill *bool `yaml:"scriptKill,omitempty"` Set *Set `yaml:"set,omitempty"` SetBit *SetBit `yaml:"setBit,omitempty"` SetRange *SetRange `yaml:"setRange,omitempty"` Shutdown *bool `yaml:"shutdown,omitempty"` ShutdownNoSave *bool `yaml:"shutdownNoSave,omitempty"` ShutdownSave *bool `yaml:"shutdownSave,omitempty"` SlaveOf *SlaveOf `yaml:"slaveOf,omitempty"` Sort *Sort `yaml:"sort,omitempty"` SortInterfaces *SortInterfaces `yaml:"sortInterfaces,omitempty"` SortStore *SortStore `yaml:"sortStore,omitempty"` TTL *TTL `yaml:"ttl,omitempty"` Time *bool `yaml:"time,omitempty"` Touch *Touch `yaml:"touch,omitempty"` Type *Type `yaml:"type,omitempty"` Unlink *Unlink `yaml:"unlink,omitempty"` Wait *Wait `yaml:"wait,omitempty"` XAck *XAck `yaml:"xAck,omitempty"` XAdd *XAdd `yaml:"xAdd,omitempty"` XClaim *XClaim `yaml:"xClaim,omitempty"` XClaimJustID *XClaimJustID `yaml:"xClaimJustID,omitempty"` XDel *XDel `yaml:"xDel,omitempty"` XGroupCreate *XGroupCreate `yaml:"xGroupCreate,omitempty"` XGroupCreateMkStream *XGroupCreateMkStream `yaml:"xGroupCreateMkStream,omitempty"` XGroupDelConsumer *XGroupDelConsumer `yaml:"xGroupDelConsumer,omitempty"` XGroupDestroy *XGroupDestroy `yaml:"xGroupDestroy,omitempty"` XGroupSetID *XGroupSetID `yaml:"xGroupSetID,omitempty"` XInfoGroups *XInfoGroups `yaml:"xInfoGroups,omitempty"` XLen *XLen `yaml:"xLen,omitempty"` XPending *XPending `yaml:"xPending,omitempty"` XPendingExt *XPendingExt `yaml:"xPendingExt,omitempty"` XRange *XRange `yaml:"xRange,omitempty"` XRangeN *XRangeN `yaml:"xRangeN,omitempty"` XRead *XRead `yaml:"xRead,omitempty"` XReadGroup *XReadGroup `yaml:"xReadGroup,omitempty"` XReadStreams *XReadStreams `yaml:"xReadStreams,omitempty"` XRevRange *XRevRange `yaml:"xRevRange,omitempty"` XRevRangeN *XRevRangeN `yaml:"xRevRangeN,omitempty"` XTrim *XTrim `yaml:"xTrim,omitempty"` XTrimApprox *XTrimApprox `yaml:"xTrimApprox,omitempty"` ZAdd *ZAdd `yaml:"zAdd,omitempty"` ZAddCh *ZAddCh `yaml:"zAddCh,omitempty"` ZAddNX *ZAddNX `yaml:"zAddNX,omitempty"` ZAddNXCh *ZAddNXCh `yaml:"zAddNXCh,omitempty"` ZAddXX *ZAddXX `yaml:"zAddXX,omitempty"` ZAddXXCh *ZAddXXCh `yaml:"zAddXXCh,omitempty"` ZCard *ZCard `yaml:"zCard,omitempty"` ZCount *ZCount `yaml:"zCount,omitempty"` ZIncr *ZIncr `yaml:"zIncr,omitempty"` ZIncrBy *ZIncrBy `yaml:"zIncrBy,omitempty"` ZIncrNX *ZIncrNX `yaml:"zIncrNX,omitempty"` ZIncrXX *ZIncrXX `yaml:"zIncrXX,omitempty"` ZInterStore *ZInterStore `yaml:"zInterStore,omitempty"` ZLexCount *ZLexCount `yaml:"zLexCount,omitempty"` ZPopMax *ZPopMax `yaml:"zPopMax,omitempty"` ZPopMin *ZPopMin `yaml:"zPopMin,omitempty"` ZRange *ZRange `yaml:"zRange,omitempty"` ZRangeByLex *ZRangeByLex `yaml:"zRangeByLex,omitempty"` ZRangeByScore *ZRangeByScore `yaml:"zRangeByScore,omitempty"` ZRangeByScoreWithScores *ZRangeByScoreWithScores `yaml:"zRangeByScoreWithScores,omitempty"` ZRangeWithScores *ZRangeWithScores `yaml:"zRangeWithScores,omitempty"` ZRank *ZRank `yaml:"zRank,omitempty"` ZRem *ZRem `yaml:"zRem,omitempty"` ZRemRangeByLex *ZRemRangeByLex `yaml:"zRemRangeByLex,omitempty"` ZRemRangeByRank *ZRemRangeByRank `yaml:"zRemRangeByRank,omitempty"` ZRemRangeByScore *ZRemRangeByScore `yaml:"zRemRangeByScore,omitempty"` ZRevRange *ZRevRange `yaml:"zRevRange,omitempty"` ZRevRangeByLex *ZRevRangeByLex `yaml:"zRevRangeByLex,omitempty"` ZRevRangeByScore *ZRevRangeByScore `yaml:"zRevRangeByScore,omitempty"` ZRevRangeByScoreWithScores *ZRevRangeByScoreWithScores `yaml:"zRevRangeByScoreWithScores,omitempty"` ZRevRangeWithScores *ZRevRangeWithScores `yaml:"zRevRangeWithScores,omitempty"` ZRevRank *ZRevRank `yaml:"zRevRank,omitempty"` ZScan *ZScan `yaml:"zScan,omitempty"` ZScore *ZScore `yaml:"zScore,omitempty"` ZUnionStore *ZUnionStore `yaml:"zUnionStore,omitempty"` }
Command is a Redis command.
type Config ¶
type Config struct { Network string `yaml:"network,omitempty"` Addr string `yaml:"addr"` DB int `yaml:"db"` Password string `yaml:"password,omitempty"` PoolSize *int `yaml:"poolSize,omitempty"` MaxRetries *int `yaml:"maxRetries,omitempty"` MinRetryBackoff *time.Duration `yaml:"minRetryBackoff,omitempty"` MaxRetryBackoff *time.Duration `yaml:"maxRetryBackoff,omitempty"` DialTimeout *time.Duration `yaml:"dialTimeout,omitempty"` ReadTimeout *time.Duration `yaml:"readTimeout,omitempty"` WriteTimeout *time.Duration `yaml:"writeTimeout,omitempty"` MaxConnAge *time.Duration `yaml:"maxConnAge,omitempty"` PoolTimeout *time.Duration `yaml:"poolTimeout,omitempty"` IdleTimeout *time.Duration `yaml:"idleTimeout,omitempty"` IdleCheckFrequency *time.Duration `yaml:"idleCheckFrequency,omitempty"` Commands []*Command `yaml:"commands"` }
Config is a config for a Redis stage.
type GeoAdd ¶
type GeoAdd struct { Key string `yaml:"key"` GeoLocation []*v7.GeoLocation `yaml:"geoLocation"` }
GeoAdd ...
type GeoDist ¶
type GeoDist struct { Key string `yaml:"key"` Member1 string `yaml:"member1"` Member2 string `yaml:"member2"` Unit string `yaml:"unit"` }
GeoDist ...
type GeoRadius ¶
type GeoRadius struct { Key string `yaml:"key"` Longitude float64 `yaml:"longitude"` Latitude float64 `yaml:"latitude"` Query v7.GeoRadiusQuery `yaml:"query"` }
GeoRadius ...
type GeoRadiusByMember ¶
type GeoRadiusByMember struct { Key string `yaml:"key"` Member string `yaml:"member"` Query *v7.GeoRadiusQuery `yaml:"query"` }
GeoRadiusByMember ...
type GeoRadiusByMemberStore ¶
type GeoRadiusByMemberStore struct { Key string `yaml:"key"` Member string `yaml:"member"` Query *v7.GeoRadiusQuery `yaml:"query"` }
GeoRadiusByMemberStore ...
type GeoRadiusStore ¶
type GeoRadiusStore struct { Key string `yaml:"key"` Longitude float64 `yaml:"longitude"` Latitude float64 `yaml:"latitude"` Query *v7.GeoRadiusQuery `yaml:"query"` }
GeoRadiusStore ...
type HIncrBy ¶
type HIncrBy struct { Key string `yaml:"key"` Field string `yaml:"field"` Incr int64 `yaml:"incr"` }
HIncrBy ...
type HIncrByFloat ¶
type HIncrByFloat struct { Key string `yaml:"key"` Field string `yaml:"field"` Incr float64 `yaml:"incr"` }
HIncrByFloat ...
type HScan ¶
type HScan struct { Key string `yaml:"key"` Cursor uint64 `yaml:"cursor"` Match string `yaml:"match"` Count int64 `yaml:"count"` }
HScan ...
type IncrByFloat ¶
IncrByFloat ...
type MemoryUsage ¶
MemoryUsage ...
type Migrate ¶
type Migrate struct { Host string `yaml:"host"` Port string `yaml:"port"` Key string `yaml:"key"` Db int `yaml:"db"` Timeout time.Duration `yaml:"timeout"` }
Migrate ...
type PubSubChannels ¶
type PubSubChannels struct {
Pattern string `yaml:"pattern"`
}
PubSubChannels ...
type PubSubNumSub ¶
type PubSubNumSub struct {
Channels []string `yaml:"channels"`
}
PubSubNumSub ...
type Restore ¶
type Restore struct { Key string `yaml:"key"` TTL time.Duration `yaml:"ttl"` Value string `yaml:"value"` }
Restore ...
type RestoreReplace ¶
type RestoreReplace struct { Key string `yaml:"key"` TTL time.Duration `yaml:"ttl"` Value string `yaml:"value"` }
RestoreReplace ...
type SDiffStore ¶
SDiffStore ...
type SInterStore ¶
SInterStore ...
type SRandMemberN ¶
SRandMemberN ...
type SScan ¶
type SScan struct { Key string `yaml:"key"` Cursor uint64 `yaml:"cursor"` Match string `yaml:"match"` Count int64 `yaml:"count"` }
SScan ...
type SUnionStore ¶
SUnionStore ...
type Scan ¶
type Scan struct { Cursor uint64 `yaml:"cursor"` Match string `yaml:"match"` Count int64 `yaml:"count"` }
Scan ...
type Set ¶
type Set struct { Key string `yaml:"key"` Value string `yaml:"value"` Expiration time.Duration `yaml:"expiration"` }
Set ...
type SetBit ¶
type SetBit struct { Key string `yaml:"key"` Offset int64 `yaml:"offset"` Value int `yaml:"value"` }
SetBit ...
type SetRange ¶
type SetRange struct { Key string `yaml:"key"` Offset int64 `yaml:"offset"` Value string `yaml:"value"` }
SetRange ...
type SortInterfaces ¶
SortInterfaces ...
type SortStore ¶
type SortStore struct { Key string `yaml:"key"` Store string `yaml:"store"` Sort *v7.Sort `yaml:"sort"` }
SortStore ...
type XAck ¶
type XAck struct { Stream string `yaml:"stream"` Group string `yaml:"group"` Ids []string `yaml:"ids"` }
XAck ...
type XGroupCreate ¶
type XGroupCreate struct { Stream string `yaml:"stream"` Group string `yaml:"group"` Start string `yaml:"start"` }
XGroupCreate ...
type XGroupCreateMkStream ¶
type XGroupCreateMkStream struct { Stream string `yaml:"stream"` Group string `yaml:"group"` Start string `yaml:"start"` }
XGroupCreateMkStream ...
type XGroupDelConsumer ¶
type XGroupDelConsumer struct { Stream string `yaml:"stream"` Group string `yaml:"group"` Consumer string `yaml:"consumer"` }
XGroupDelConsumer ...
type XGroupDestroy ¶
XGroupDestroy ...
type XGroupSetID ¶
type XGroupSetID struct { Stream string `yaml:"stream"` Group string `yaml:"group"` Start string `yaml:"start"` }
XGroupSetID ...
type XRange ¶
type XRange struct { Stream string `yaml:"stream"` Start string `yaml:"start"` Stop string `yaml:"stop"` }
XRange ...
type XRangeN ¶
type XRangeN struct { Stream string `yaml:"stream"` Start string `yaml:"start"` Stop string `yaml:"stop"` Count int64 `yaml:"count"` }
XRangeN ...
type XRevRange ¶
type XRevRange struct { Stream string `yaml:"stream"` Start string `yaml:"start"` Stop string `yaml:"stop"` }
XRevRange ...
type XRevRangeN ¶
type XRevRangeN struct { Stream string `yaml:"stream"` Start string `yaml:"start"` Stop string `yaml:"stop"` Count int64 `yaml:"count"` }
XRevRangeN ...
type XTrimApprox ¶
XTrimApprox ...
type ZIncrBy ¶
type ZIncrBy struct { Key string `yaml:"key"` Increment float64 `yaml:"increment"` Member string `yaml:"member"` }
ZIncrBy ...
type ZInterStore ¶
ZInterStore ...
type ZRangeByLex ¶
ZRangeByLex ...
type ZRangeByScore ¶
ZRangeByScore ...
type ZRangeByScoreWithScores ¶
ZRangeByScoreWithScores ...
type ZRangeWithScores ¶
type ZRangeWithScores struct { Key string `yaml:"key"` Start int64 `yaml:"start"` Stop int64 `yaml:"stop"` }
ZRangeWithScores ...
type ZRemRangeByLex ¶
type ZRemRangeByLex struct { Key string `yaml:"key"` Min string `yaml:"min"` Max string `yaml:"max"` }
ZRemRangeByLex ...
type ZRemRangeByRank ¶
type ZRemRangeByRank struct { Key string `yaml:"key"` Start int64 `yaml:"start"` Stop int64 `yaml:"stop"` }
ZRemRangeByRank ...
type ZRemRangeByScore ¶
type ZRemRangeByScore struct { Key string `yaml:"key"` Min string `yaml:"min"` Max string `yaml:"max"` }
ZRemRangeByScore ...
type ZRevRange ¶
type ZRevRange struct { Key string `yaml:"key"` Start int64 `yaml:"start"` Stop int64 `yaml:"stop"` }
ZRevRange ...
type ZRevRangeByLex ¶
ZRevRangeByLex ...
type ZRevRangeByScore ¶
ZRevRangeByScore ...
type ZRevRangeByScoreWithScores ¶
ZRevRangeByScoreWithScores ...
type ZRevRangeWithScores ¶
type ZRevRangeWithScores struct { Key string `yaml:"key"` Start int64 `yaml:"start"` Stop int64 `yaml:"stop"` }
ZRevRangeWithScores ...
type ZScan ¶
type ZScan struct { Key string `yaml:"key"` Cursor uint64 `yaml:"cursor"` Match string `yaml:"match"` Count int64 `yaml:"count"` }
ZScan ...
type ZUnionStore ¶
ZUnionStore ...