Versions in this module Expand all Collapse all v1 v1.0.10 Sep 11, 2020 Changes in this version + const DefaultDialTimeout + const DefaultReadTimeout + const DefaultWriteTimeout + var ErrKeyHasNoExpiration = errors.New("go-redis: key exists but has no associated expire") + var ErrKeyNotExist = errors.New("go-redis: key does not exist") + var ErrNotImplemented = errors.New("go0redis: command is not implemented") + var ErrUnexpectedResponseType = errors.New("go-redis: unexpected type of the response") + var ErrUnsupportedValueType = errors.New("go-redis: unsupported value type") + type BulkString struct + func MakeBulkString(str string) BulkString + func Null() BulkString + func (bs BulkString) IsNull() bool + func (bs BulkString) String() string + type ChanAndSub struct + Chan string + Sub int + func MakeChanAndSub(ch string, sub int) ChanAndSub + type ChanAndSubs []ChanAndSub + func (css ChanAndSubs) Map() map[string]int + type ClientConfig struct + Addr string + DB int + DialTimeout time.Duration + Password string + PoolSize int + ReadTimeout time.Duration + WriteTimeout time.Duration + type Cluster interface + type ClusterConfig struct + Addrs []string + DialTimeout time.Duration + Password string + PoolSize int + ReadTimeout time.Duration + WriteTimeout time.Duration + type Config struct + Client *ClientConfig + Cluster *ClusterConfig + Failover *FailoverConfig + type Connection interface + Echo func(msg string) (echo BulkString, err error) + Ping func() (err error) + type Factory struct + func NewFactory(config *Config) *Factory + func Register(section string) **Factory + func (f *Factory) Close() error + func (f *Factory) Conn(ctx context.Context) error + func (f *Factory) New(ctx context.Context) Redis + type FailoverConfig struct + DialTimeout time.Duration + MasterName string + Password string + PoolSize int + ReadTimeout time.Duration + SentinelAddrs []string + WriteTimeout time.Duration + type FlushOption int + func Async() FlushOption + type FutureMultiValue struct + func (fmv *FutureMultiValue) Error() string + func (fmv *FutureMultiValue) MultiValue() MultiValue + type GEO interface + type Generic interface + Del func(keys ...string) (deleted int, err error) + Dump func(key string) (value BulkString, err error) + Exists func(keys ...string) (existing int, err error) + Expire func(key string, timeout time.Duration) (isSet bool, err error) + ExpireAt func(key string, t time.Time) (isSet bool, err error) + Keys func(pattern string) (keys []BulkString, err error) + Persist func(key string) (persisted bool, err error) + RandomKey func() (key BulkString, err error) + Rename func(old, new string) (err error) + RenameNX func(old, new string) (renamed bool, err error) + TTL func(key string) (ttl time.Duration, err error) + Touch func(keys ...string) (touched int, err error) + Type func(key string) (keyType KeyType, err error) + Unlink func(keys ...string) (unlinked int, err error) + type Hashes interface + HDel func(key string, fields ...string) (deleted int, err error) + HExists func(key string, field string) (exists bool, err error) + HGet func(key string, field string) (value BulkString, err error) + HGetAll func(key string) (fieldAndValues KeyAndValues, err error) + HIncrBy func(key string, field string, incr int64) (value int64, err error) + HIncrByFloat func(key string, field string, incr float64) (value float64, err error) + HKeys func(key string) (keys []BulkString, err error) + HLen func(key string) (l int, err error) + HMGet func(key string, fields ...string) (values []BulkString, err error) + HMSet func(key string, fieldAndValues ...KeyAndValue) (err error) + HSet func(key string, field string, value string) (isNew bool, err error) + HSetNX func(key string, field string, value string) (isNew bool, err error) + HVals func(key string) (values []BulkString, err error) + type HyperLogLog interface + type KeyAndValue struct + Key string + Value string + func MakeKeyAndValue(key string, value string) KeyAndValue + type KeyAndValues []KeyAndValue + func (kvs KeyAndValues) Map() map[string]string + type KeyType string + const TypeHash + const TypeList + const TypeSet + const TypeStream + const TypeString + const TypeZSet + type Lists interface + LIndex func(key string, index int) (value BulkString, err error) + LInsertAfter func(key string, pivot string, value string) (l int, err error) + LInsertBefore func(key string, pivot string, value string) (l int, err error) + LLen func(key string) (l int, err error) + LPop func(key string) (value BulkString, err error) + LPush func(key string, values ...string) (l int, err error) + LPushX func(key string, value string) (l int, err error) + LRange func(key string, start int, stop int) (values []BulkString, err error) + LRem func(key string, count int, value string) (removed int, err error) + LSet func(key string, index int, value string) (err error) + LTrim func(key string, start int, stop int) (err error) + RPop func(key string) (value BulkString, err error) + RPopLPush func(src string, dst string) (value BulkString, err error) + RPush func(key string, values ...string) (l int, err error) + RPushX func(key string, value string) (l int, err error) + type MemberAndScore struct + Member string + Score float64 + func MakeMemberAndScore(member string, score float64) MemberAndScore + type MemberAndScores []MemberAndScore + func (mss MemberAndScores) Map() map[string]float64 + type MemberRange string + const MemberRangeStart + const MemberRangeStop + func MakeMemberRange(member string) MemberRange + func (mr MemberRange) Exclusive() MemberRange + func (mr MemberRange) IsValid() bool + func (mr MemberRange) String() string + type MultiValue struct + func MakeMultiValue(v interface{}) (mv MultiValue) + func (mv MultiValue) Bool() (v bool, ok bool) + func (mv MultiValue) BulkString() (v BulkString, ok bool) + func (mv MultiValue) Duration() (d time.Duration, ok bool) + func (mv MultiValue) Err() error + func (mv MultiValue) Float64() (n float64, ok bool) + func (mv MultiValue) Int() (n int, ok bool) + func (mv MultiValue) Int64() (n int64, ok bool) + func (mv MultiValue) IsErr() bool + func (mv MultiValue) IsNil() bool + func (mv MultiValue) KeyAndValue() (kv KeyAndValue, ok bool) + func (mv MultiValue) MemberAndScore() (ms MemberAndScore, ok bool) + func (mv MultiValue) MultiValues() (mvs []MultiValue, ok bool) + func (mv MultiValue) Status() (s string, ok bool) + func (mv MultiValue) String() string + func (mv MultiValue) Time() (t time.Time, ok bool) + type PubSub interface + type RangeOption struct + func Limit(offset int, count int) RangeOption + func (ro *RangeOption) Args() []interface{} + type Redis interface + func New(ctx context.Context) Redis + type Scan interface + type ScanOption struct + func Count(count int) ScanOption + func Match(pattern string) ScanOption + func (so *ScanOption) Args() []interface{} + type ScoreRange string + func MakeScoreRange(score float64) ScoreRange + func (sr ScoreRange) Exclusive() ScoreRange + func (sr ScoreRange) IsValid() bool + func (sr ScoreRange) String() string + type Scripting interface + type Server interface + FlushAll func(options ...FlushOption) (err error) + type SetOption struct + func Expire(timeout time.Duration) SetOption + func NX() SetOption + func XX() SetOption + func (so *SetOption) Args() []interface{} + type Sets interface + SAdd func(key string, members ...string) (added int, err error) + SCard func(key string) (count int, err error) + SDiff func(keys ...string) (members []BulkString, err error) + SDiffStore func(dst string, keys ...string) (count int, err error) + SInter func(keys ...string) (members []BulkString, err error) + SInterStore func(dst string, keys ...string) (count int, err error) + SIsMember func(key string, member string) (exists bool, err error) + SMembers func(key string) (members []BulkString, err error) + SMove func(src string, dst string, member string) (moved bool, err error) + SPop func(key string) (member BulkString, err error) + SPopN func(key string, count int) (members []BulkString, err error) + SRandMember func(key string) (member BulkString, err error) + SRandMemberN func(key string, count int) (members []BulkString, err error) + SRem func(key string, members ...string) (removed int, err error) + SUnion func(keys ...string) (members []BulkString, err error) + SUnionStore func(dst string, keys ...string) (count int, err error) + type SortedSets interface + ZAdd func(key string, mss ...MemberAndScore) (added int, err error) + ZCard func(key string) (count int, err error) + ZCount func(key string, min ScoreRange, max ScoreRange) (count int, err error) + ZIncrBy func(key string, incr float64, member string) (score float64, err error) + ZInterStore func(dst string, keys []string, options ...StoreOption) (count int, err error) + ZLexCount func(key string, min MemberRange, max MemberRange) (count int, err error) + ZPopMax func(key string) (ms MemberAndScore, err error) + ZPopMaxN func(key string, count int) (mss MemberAndScores, err error) + ZPopMin func(key string) (ms MemberAndScore, err error) + ZPopMinN func(key string, count int) (mss MemberAndScores, err error) + ZRange func(key string, start float64, stop float64) (members []BulkString, err error) + ZRangeByLex func(key string, min MemberRange, max MemberRange, options ...RangeOption) (members []BulkString, err error) + ZRangeByScore func(key string, min ScoreRange, max ScoreRange, options ...RangeOption) (members []BulkString, err error) + ZRangeByScoreWithScores func(key string, min ScoreRange, max ScoreRange, options ...RangeOption) (mss MemberAndScores, err error) + ZRangeWithScores func(key string, start float64, stop float64) (mss MemberAndScores, err error) + ZRank func(key string, member string) (rank int, exists bool, err error) + ZRem func(key string, members ...string) (removed int, err error) + ZRemRangeByLex func(key string, min MemberRange, max MemberRange) (removed int, err error) + ZRemRangeByRank func(key string, start int, stop int) (removed int, err error) + ZRemRangeByScore func(key string, min ScoreRange, max ScoreRange) (removed int, err error) + ZRevRange func(key string, start float64, stop float64) (members []BulkString, err error) + ZRevRangeByLex func(key string, min MemberRange, max MemberRange, options ...RangeOption) (members []BulkString, err error) + ZRevRangeByScore func(key string, min ScoreRange, max ScoreRange, options ...RangeOption) (members []BulkString, err error) + ZRevRangeByScoreWithScores func(key string, min ScoreRange, max ScoreRange, options ...RangeOption) (mss MemberAndScores, err error) + ZRevRangeWithScores func(key string, start float64, stop float64) (mss MemberAndScores, err error) + ZRevRank func(key string, member string) (rank int, exists bool, err error) + ZScore func(key string, member string) (score float64, exists bool, err error) + ZUnionStore func(dst string, keys []string, options ...StoreOption) (count int, err error) + type StoreOption struct + func AggregateMax() StoreOption + func AggregateMin() StoreOption + func AggregateSum() StoreOption + func Weights(weights ...float64) StoreOption + func (so *StoreOption) Args() []interface{} + type Streams interface + type Strings interface + Append func(key string, value string) (l int, err error) + Decr func(key string) (value int64, err error) + DecrBy func(key string, decr int64) (value int64, err error) + Get func(key string) (value BulkString, err error) + GetRange func(key string, start int, end int) (value BulkString, err error) + GetSet func(key string, value string) (old BulkString, err error) + Incr func(key string) (value int64, err error) + IncrBy func(key string, incr int64) (value int64, err error) + IncrByFloat func(key string, incr float64) (value float64, err error) + MGet func(keys ...string) (values []BulkString, err error) + MSet func(kvs ...KeyAndValue) (err error) + MSetNX func(kvs ...KeyAndValue) (isSet bool, err error) + Set func(key string, value string, options ...SetOption) (isSet bool, err error) + SetEx func(key string, timeout time.Duration, value string) (err error) + SetNX func(key string, value string) (isSet bool, err error) + SetRange func(key string, offset int, value string) (modified int, err error) + StrLen func(key string) (l int, err error) + type Transactions interface
Go to main page