Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pool

package module

Go to main page

Versions in this module

v1

v1.0.6

Jan 14, 2023

v1.0.5

Jan 14, 2023

v1.0.4

Jan 14, 2023

v1.0.3

Jan 14, 2023

v1.0.2

Jan 14, 2023

Changes in this version

type Pool

+ func (p *Pool) Do(ctx context.Context, args ...interface{}) *redis.Cmd

v1.0.1

Jan 14, 2023

Changes in this version

+ const DistributeByKetama

+ const DistributeByModular

+ const PollByRandom

+ const PollByRoundRobin

+ const PollByWeight

+ type ConnFactory interface

+ type HAConfig struct

+ AutoEjectHost bool

+ Master string

+ MinServerNum int

+ Options *redis.Options

+ Password string

+ PollType int

+ ReadonlyPassword string

+ ServerFailureLimit int32

+ ServerRetryTimeout time.Duration

+ Slaves []string

+ type HAConnFactory struct

+ func NewHAConnFactory(cfg *HAConfig) (*HAConnFactory, error)

+ type Pool struct

+ func NewHA(cfg *HAConfig) (*Pool, error)

+ func NewShard(cfg *ShardConfig) (*Pool, error)

+ func (p *Pool) Append(ctx context.Context, key, value string) *redis.IntCmd

+ func (p *Pool) BLPop(ctx context.Context, timeout time.Duration, keys ...string) *redis.StringSliceCmd

+ func (p *Pool) BRPop(ctx context.Context, timeout time.Duration, keys ...string) *redis.StringSliceCmd

+ func (p *Pool) BRPopLPush(ctx context.Context, source, destination string, timeout time.Duration) *redis.StringCmd

+ func (p *Pool) BitCount(ctx context.Context, key string, bitCount *redis.BitCount) *redis.IntCmd

+ func (p *Pool) BitField(ctx context.Context, key string, args ...interface{}) *redis.IntSliceCmd

+ func (p *Pool) BitOp(ctx context.Context, op int, destKey string, keys ...string) *redis.IntCmd

+ func (p *Pool) BitOpAnd(ctx context.Context, destKey string, keys ...string) *redis.IntCmd

+ func (p *Pool) BitOpNot(ctx context.Context, destKey string, key string) *redis.IntCmd

+ func (p *Pool) BitOpOr(ctx context.Context, destKey string, keys ...string) *redis.IntCmd

+ func (p *Pool) BitOpXor(ctx context.Context, destKey string, keys ...string) *redis.IntCmd

+ func (p *Pool) BitPos(ctx context.Context, key string, bit int64, pos ...int64) *redis.IntCmd

+ func (p *Pool) Close()

+ func (p *Pool) DebugObject(ctx context.Context, key string) *redis.StringCmd

+ func (p *Pool) Decr(ctx context.Context, key string) *redis.IntCmd

+ func (p *Pool) DecrBy(ctx context.Context, key string, decrement int64) *redis.IntCmd

+ func (p *Pool) Del(ctx context.Context, keys ...string) (int64, error)

+ func (p *Pool) Dump(ctx context.Context, key string) *redis.StringCmd

+ func (p *Pool) Echo(ctx context.Context, message interface{}) *redis.StringCmd

+ func (p *Pool) Eval(ctx context.Context, script string, keys []string, args ...interface{}) *redis.Cmd

+ func (p *Pool) EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *redis.Cmd

+ func (p *Pool) Exists(ctx context.Context, keys ...string) (int64, error)

+ func (p *Pool) Expire(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd

+ func (p *Pool) ExpireAt(ctx context.Context, key string, tm time.Time) *redis.BoolCmd

+ func (p *Pool) GeoAdd(ctx context.Context, key string, geoLocation ...*redis.GeoLocation) *redis.IntCmd

+ func (p *Pool) GeoDist(ctx context.Context, key string, member1, member2, unit string) *redis.FloatCmd

+ func (p *Pool) GeoHash(ctx context.Context, key string, members ...string) *redis.StringSliceCmd

+ func (p *Pool) GeoPos(ctx context.Context, key string, members ...string) *redis.GeoPosCmd

+ func (p *Pool) GeoRadius(ctx context.Context, key string, longitude, latitude float64, ...) *redis.GeoLocationCmd

+ func (p *Pool) GeoRadiusByMember(ctx context.Context, key, member string, query *redis.GeoRadiusQuery) *redis.GeoLocationCmd

+ func (p *Pool) GeoRadiusByMemberStore(ctx context.Context, key, member string, query *redis.GeoRadiusQuery) *redis.IntCmd

+ func (p *Pool) GeoRadiusStore(ctx context.Context, key string, longitude, latitude float64, ...) *redis.IntCmd

+ func (p *Pool) Get(ctx context.Context, key string) *redis.StringCmd

+ func (p *Pool) GetBit(ctx context.Context, key string, offset int64) *redis.IntCmd

+ func (p *Pool) GetRange(ctx context.Context, key string, start, end int64) *redis.StringCmd

+ func (p *Pool) GetSet(ctx context.Context, key string, value interface{}) *redis.StringCmd

+ func (p *Pool) HDel(ctx context.Context, key string, fields ...string) *redis.IntCmd

+ func (p *Pool) HExists(ctx context.Context, key, field string) *redis.BoolCmd

+ func (p *Pool) HGet(ctx context.Context, key, field string) *redis.StringCmd

+ func (p *Pool) HGetAll(ctx context.Context, key string) *redis.StringStringMapCmd

+ func (p *Pool) HIncrBy(ctx context.Context, key, field string, incr int64) *redis.IntCmd

+ func (p *Pool) HIncrByFloat(ctx context.Context, key, field string, incr float64) *redis.FloatCmd

+ func (p *Pool) HKeys(ctx context.Context, key string) *redis.StringSliceCmd

+ func (p *Pool) HLen(ctx context.Context, key string) *redis.IntCmd

+ func (p *Pool) HMGet(ctx context.Context, key string, fields ...string) *redis.SliceCmd

+ func (p *Pool) HMSet(ctx context.Context, key string, values ...interface{}) *redis.BoolCmd

+ func (p *Pool) HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd

+ func (p *Pool) HSet(ctx context.Context, key, field string, value interface{}) *redis.IntCmd

+ func (p *Pool) HSetNX(ctx context.Context, key, field string, value interface{}) *redis.BoolCmd

+ func (p *Pool) HVals(ctx context.Context, key string) *redis.StringSliceCmd

+ func (p *Pool) Incr(ctx context.Context, key string) *redis.IntCmd

+ func (p *Pool) IncrBy(ctx context.Context, key string, increment int64) *redis.IntCmd

+ func (p *Pool) IncrByFloat(ctx context.Context, key string, value float64) *redis.FloatCmd

+ func (p *Pool) Keys(ctx context.Context, key string) *redis.StringSliceCmd

+ func (p *Pool) LIndex(ctx context.Context, key string, index int64) *redis.StringCmd

+ func (p *Pool) LInsert(ctx context.Context, key, op string, pivot, value interface{}) *redis.IntCmd

+ func (p *Pool) LInsertAfter(ctx context.Context, key string, pivot, value interface{}) *redis.IntCmd

+ func (p *Pool) LInsertBefore(ctx context.Context, key string, pivot, value interface{}) *redis.IntCmd

+ func (p *Pool) LLen(ctx context.Context, key string) *redis.IntCmd

+ func (p *Pool) LPop(ctx context.Context, key string) *redis.StringCmd

+ func (p *Pool) LPush(ctx context.Context, key string, values ...interface{}) *redis.IntCmd

+ func (p *Pool) LPushX(ctx context.Context, key string, values ...interface{}) *redis.IntCmd

+ func (p *Pool) LRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd

+ func (p *Pool) LRem(ctx context.Context, key string, count int64, value interface{}) *redis.IntCmd

+ func (p *Pool) LSet(ctx context.Context, key string, index int64, value interface{}) *redis.StatusCmd

+ func (p *Pool) LTrim(ctx context.Context, key string, start, stop int64) *redis.StatusCmd

+ func (p *Pool) MGet(ctx context.Context, keys ...string) ([]interface{}, error)

+ func (p *Pool) MGetWithGD(ctx context.Context, keys ...string) ([]interface{}, map[string]error)

+ func (p *Pool) MSet(ctx context.Context, values ...interface{}) *redis.StatusCmd

+ func (p *Pool) MSetNX(ctx context.Context, values ...interface{}) *redis.BoolCmd

+ func (p *Pool) MSetWithGD(ctx context.Context, values ...interface{}) []*redis.StatusCmd

+ func (p *Pool) MemoryUsage(ctx context.Context, key string, samples ...int) *redis.IntCmd

+ func (p *Pool) ObjectEncoding(ctx context.Context, key string) *redis.StringCmd

+ func (p *Pool) ObjectIdleTime(ctx context.Context, key string) *redis.DurationCmd

+ func (p *Pool) ObjectRefCount(ctx context.Context, key string) *redis.IntCmd

+ func (p *Pool) PFAdd(ctx context.Context, key string, els ...interface{}) *redis.IntCmd

+ func (p *Pool) PFCount(ctx context.Context, keys ...string) *redis.IntCmd

+ func (p *Pool) PFMerge(ctx context.Context, dest string, keys ...string) *redis.StatusCmd

+ func (p *Pool) Ping(ctx context.Context) *redis.StatusCmd

+ func (p *Pool) Pipeline() (redis.Pipeliner, error)

+ func (p *Pool) Pipelined(ctx context.Context, fn func(redis.Pipeliner) error) ([]redis.Cmder, error)

+ func (p *Pool) PubSubChannels(ctx context.Context, pattern string) *redis.StringSliceCmd

+ func (p *Pool) PubSubNumPat(ctx context.Context) *redis.IntCmd

+ func (p *Pool) PubSubNumSub(ctx context.Context, channels ...string) *redis.StringIntMapCmd

+ func (p *Pool) Publish(ctx context.Context, channel string, message interface{}) *redis.IntCmd

+ func (p *Pool) RPop(ctx context.Context, key string) *redis.StringCmd

+ func (p *Pool) RPopLPush(ctx context.Context, source, destination string) *redis.StringCmd

+ func (p *Pool) RPush(ctx context.Context, key string, values ...interface{}) *redis.IntCmd

+ func (p *Pool) RPushX(ctx context.Context, key string, values ...interface{}) *redis.IntCmd

+ func (p *Pool) Rename(ctx context.Context, key, newkey string) *redis.StatusCmd

+ func (p *Pool) RenameNX(ctx context.Context, key, newkey string) *redis.BoolCmd

+ func (p *Pool) SAdd(ctx context.Context, key string, members ...interface{}) *redis.IntCmd

+ func (p *Pool) SCard(ctx context.Context, key string) *redis.IntCmd

+ func (p *Pool) SDiff(ctx context.Context, keys ...string) *redis.StringSliceCmd

+ func (p *Pool) SDiffStore(ctx context.Context, destination string, keys ...string) *redis.IntCmd

+ func (p *Pool) SInter(ctx context.Context, keys ...string) *redis.StringSliceCmd

+ func (p *Pool) SInterStore(ctx context.Context, destination string, keys ...string) *redis.IntCmd

+ func (p *Pool) SIsMember(ctx context.Context, key string, member interface{}) *redis.BoolCmd

+ func (p *Pool) SMembers(ctx context.Context, key string) *redis.StringSliceCmd

+ func (p *Pool) SMembersMap(ctx context.Context, key string) *redis.StringStructMapCmd

+ func (p *Pool) SMove(ctx context.Context, source, destination string, member interface{}) *redis.BoolCmd

+ func (p *Pool) SPop(ctx context.Context, key string) *redis.StringCmd

+ func (p *Pool) SPopN(ctx context.Context, key string, count int64) *redis.StringSliceCmd

+ func (p *Pool) SRandMember(ctx context.Context, key string) *redis.StringCmd

+ func (p *Pool) SRandMemberN(ctx context.Context, key string, count int64) *redis.StringSliceCmd

+ func (p *Pool) SRem(ctx context.Context, key string, members ...interface{}) *redis.IntCmd

+ func (p *Pool) SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd

+ func (p *Pool) SUnion(ctx context.Context, keys ...string) *redis.StringSliceCmd

+ func (p *Pool) SUnionStore(ctx context.Context, destination string, keys ...string) *redis.IntCmd

+ func (p *Pool) Scan(ctx context.Context, cursor uint64, match string, count int64) *redis.ScanCmd

+ func (p *Pool) ScriptExists(ctx context.Context, hashes ...string) *redis.BoolSliceCmd

+ func (p *Pool) ScriptFlush(ctx context.Context) *redis.StatusCmd

+ func (p *Pool) ScriptKill(ctx context.Context) *redis.StatusCmd

+ func (p *Pool) ScriptLoad(ctx context.Context, script string) *redis.StringCmd

+ func (p *Pool) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd

+ func (p *Pool) SetBit(ctx context.Context, key string, offset int64, value int) *redis.IntCmd

+ func (p *Pool) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.BoolCmd

+ func (p *Pool) SetRange(ctx context.Context, key string, offset int64, value string) *redis.IntCmd

+ func (p *Pool) SetXX(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.BoolCmd

+ func (p *Pool) Sort(ctx context.Context, key string, sort *redis.Sort) *redis.StringSliceCmd

+ func (p *Pool) SortInterfaces(ctx context.Context, key string, sort *redis.Sort) *redis.SliceCmd

+ func (p *Pool) SortStore(ctx context.Context, key, store string, sort *redis.Sort) *redis.IntCmd

+ func (p *Pool) Stats() map[string]*redis.PoolStats

+ func (p *Pool) StrLen(ctx context.Context, key string) *redis.IntCmd

+ func (p *Pool) TTL(ctx context.Context, key string) *redis.DurationCmd

+ func (p *Pool) Touch(ctx context.Context, keys ...string) (int64, error)

+ func (p *Pool) TxPipeline() (redis.Pipeliner, error)

+ func (p *Pool) TxPipelined(ctx context.Context, fn func(redis.Pipeliner) error) ([]redis.Cmder, error)

+ func (p *Pool) Type(ctx context.Context, key string) *redis.StatusCmd

+ func (p *Pool) Unlink(ctx context.Context, keys ...string) (int64, error)

+ func (p *Pool) WithMaster(key ...string) (*redis.Client, error)

+ func (p *Pool) ZAdd(ctx context.Context, key string, members ...*redis.Z) *redis.IntCmd

+ func (p *Pool) ZAddCh(ctx context.Context, key string, members ...*redis.Z) *redis.IntCmd

+ func (p *Pool) ZAddNX(ctx context.Context, key string, members ...*redis.Z) *redis.IntCmd

+ func (p *Pool) ZAddNXCh(ctx context.Context, key string, members ...*redis.Z) *redis.IntCmd

+ func (p *Pool) ZAddXX(ctx context.Context, key string, members ...*redis.Z) *redis.IntCmd

+ func (p *Pool) ZAddXXCh(ctx context.Context, key string, members ...*redis.Z) *redis.IntCmd

+ func (p *Pool) ZCard(ctx context.Context, key string) *redis.IntCmd

+ func (p *Pool) ZCount(ctx context.Context, key, min, max string) *redis.IntCmd

+ func (p *Pool) ZIncr(ctx context.Context, key string, member *redis.Z) *redis.FloatCmd

+ func (p *Pool) ZIncrBy(ctx context.Context, key string, increment float64, member string) *redis.FloatCmd

+ func (p *Pool) ZIncrNX(ctx context.Context, key string, member *redis.Z) *redis.FloatCmd

+ func (p *Pool) ZIncrXX(ctx context.Context, key string, member *redis.Z) *redis.FloatCmd

+ func (p *Pool) ZInterStore(ctx context.Context, destination string, store *redis.ZStore) *redis.IntCmd

+ func (p *Pool) ZLexCount(ctx context.Context, key, min, max string) *redis.IntCmd

+ func (p *Pool) ZPopMax(ctx context.Context, key string, count ...int64) *redis.ZSliceCmd

+ func (p *Pool) ZPopMin(ctx context.Context, key string, count ...int64) *redis.ZSliceCmd

+ func (p *Pool) ZRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd

+ func (p *Pool) ZRangeByLex(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.StringSliceCmd

+ func (p *Pool) ZRangeByScore(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.StringSliceCmd

+ func (p *Pool) ZRangeByScoreWithScores(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.ZSliceCmd

+ func (p *Pool) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *redis.ZSliceCmd

+ func (p *Pool) ZRank(ctx context.Context, key, member string) *redis.IntCmd

+ func (p *Pool) ZRem(ctx context.Context, key string, members ...interface{}) *redis.IntCmd

+ func (p *Pool) ZRemRangeByLex(ctx context.Context, key, min, max string) *redis.IntCmd

+ func (p *Pool) ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *redis.IntCmd

+ func (p *Pool) ZRemRangeByScore(ctx context.Context, key, min, max string) *redis.IntCmd

+ func (p *Pool) ZRevRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd

+ func (p *Pool) ZRevRangeByLex(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.StringSliceCmd

+ func (p *Pool) ZRevRangeByScore(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.StringSliceCmd

+ func (p *Pool) ZRevRangeByScoreWithScores(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.ZSliceCmd

+ func (p *Pool) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *redis.ZSliceCmd

+ func (p *Pool) ZRevRank(ctx context.Context, key, member string) *redis.IntCmd

+ func (p *Pool) ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd

+ func (p *Pool) ZScore(ctx context.Context, key, member string) *redis.FloatCmd

+ func (p *Pool) ZUnionStore(ctx context.Context, dest string, store *redis.ZStore) *redis.IntCmd

+ type ShardConfig struct

+ DistributeType int

+ HashFn func(key []byte) uint32

+ Shards []*HAConfig

+ type ShardConnFactory struct

+ func NewShardConnFactory(cfg *ShardConfig) (*ShardConnFactory, error)