Versions in this module Expand all Collapse all v1 v1.1.1 Mar 26, 2024 Changes in this version + var DumpMaxLineLen = 60 + var ErrFloatValueError = errors.New(msgInvalidFloat) + var ErrIntValueError = errors.New(msgInvalidInt) + var ErrIntValueOverflowError = errors.New(msgIntOverflow) + var ErrKeyNotFound = errors.New(msgKeyNotFound) + var ErrNotValidHllValue = errors.New(msgNotValidHllValue) + var ErrWrongType = errors.New(msgWrongType) + type Miniredis struct + Ctx context.Context + CtxCancel context.CancelFunc + func NewMiniRedis() *Miniredis + func Run() (*Miniredis, error) + func RunT(t Tester) *Miniredis + func RunTLS(cfg *tls.Config) (*Miniredis, error) + func (m *Miniredis) Addr() string + func (m *Miniredis) CheckGet(t T, key, expected string) + func (m *Miniredis) CheckList(t T, key string, expected ...string) + func (m *Miniredis) CheckSet(t T, key string, expected ...string) + func (m *Miniredis) Close() + func (m *Miniredis) CommandCount() int + func (m *Miniredis) Copy(srcDB int, src string, destDB int, dest string) error + func (m *Miniredis) CurrentConnectionCount() int + func (m *Miniredis) DB(i int) *RedisDB + func (m *Miniredis) Del(k string) bool + func (m *Miniredis) Dump() string + func (m *Miniredis) Exists(k string) bool + func (m *Miniredis) FastForward(duration time.Duration) + func (m *Miniredis) FlushAll() + func (m *Miniredis) FlushDB() + func (m *Miniredis) Get(k string) (string, error) + func (m *Miniredis) HDel(k, f string) + func (m *Miniredis) HGet(k, f string) string + func (m *Miniredis) HIncr(k, f string, delta int) (int, error) + func (m *Miniredis) HIncrBy(k, f string, delta int) (int, error) + func (m *Miniredis) HIncrByFloat(k, f string, delta float64) (float64, error) + func (m *Miniredis) HIncrfloat(k, f string, delta float64) (float64, error) + func (m *Miniredis) HKeys(k string) ([]string, error) + func (m *Miniredis) HSet(k string, fv ...string) + func (m *Miniredis) Host() string + func (m *Miniredis) Incr(k string, delta int) (int, error) + func (m *Miniredis) IncrByFloat(k string, delta float64) (float64, error) + func (m *Miniredis) Incrfloat(k string, delta float64) (float64, error) + func (m *Miniredis) IsMember(k, v string) (bool, error) + func (m *Miniredis) Keys() []string + func (m *Miniredis) List(k string) ([]string, error) + func (m *Miniredis) Lpop(k string) (string, error) + func (m *Miniredis) Lpush(k, v string) (int, error) + func (m *Miniredis) Members(k string) ([]string, error) + func (m *Miniredis) NewSubscriber() *Subscriber + func (m *Miniredis) PfAdd(k string, elems ...string) (int, error) + func (m *Miniredis) PfCount(keys ...string) (int, error) + func (m *Miniredis) PfMerge(destKey string, sourceKeys ...string) error + func (m *Miniredis) Pop(k string) (string, error) + func (m *Miniredis) Port() string + func (m *Miniredis) PubSubChannels(pattern string) []string + func (m *Miniredis) PubSubNumPat() int + func (m *Miniredis) PubSubNumSub(channels ...string) map[string]int + func (m *Miniredis) Publish(channel, message string) int + func (m *Miniredis) Push(k string, v ...string) (int, error) + func (m *Miniredis) RPop(k string) (string, error) + func (m *Miniredis) RPush(k string, v ...string) (int, error) + func (m *Miniredis) RequireAuth(pw string) + func (m *Miniredis) RequireUserAuth(username, pw string) + func (m *Miniredis) Restart() error + func (m *Miniredis) SAdd(k string, elems ...string) (int, error) + func (m *Miniredis) SIsMember(k, v string) (bool, error) + func (m *Miniredis) SMembers(k string) ([]string, error) + func (m *Miniredis) SRem(k string, fields ...string) (int, error) + func (m *Miniredis) Seed(seed int) + func (m *Miniredis) Select(i int) + func (m *Miniredis) Server() *server.Server + func (m *Miniredis) Set(k, v string) error + func (m *Miniredis) SetAdd(k string, elems ...string) (int, error) + func (m *Miniredis) SetError(msg string) + func (m *Miniredis) SetPort(port int) + func (m *Miniredis) SetTTL(k string, ttl time.Duration) + func (m *Miniredis) SetTime(t time.Time) + func (m *Miniredis) SortedSet(k string) (map[string]float64, error) + func (m *Miniredis) Start() error + func (m *Miniredis) StartAddr(addr string) error + func (m *Miniredis) StartTLS(cfg *tls.Config) error + func (m *Miniredis) Stream(k string) ([]StreamEntry, error) + func (m *Miniredis) SwapDB(i, j int) bool + func (m *Miniredis) TTL(k string) time.Duration + func (m *Miniredis) TotalConnectionCount() int + func (m *Miniredis) Type(k string) string + func (m *Miniredis) Unlink(k string) bool + func (m *Miniredis) XAdd(k string, id string, values []string) (string, error) + func (m *Miniredis) ZAdd(k string, score float64, member string) (bool, error) + func (m *Miniredis) ZMScore(k string, members ...string) ([]float64, error) + func (m *Miniredis) ZMembers(k string) ([]string, error) + func (m *Miniredis) ZRem(k, member string) (bool, error) + func (m *Miniredis) ZScore(k, member string) (float64, error) + type PubsubMessage struct + Channel string + Message string + type PubsubPmessage struct + Channel string + Message string + Pattern string + type RedisDB struct + func (db *RedisDB) Del(k string) bool + func (db *RedisDB) Exists(k string) bool + func (db *RedisDB) FlushDB() + func (db *RedisDB) Get(k string) (string, error) + func (db *RedisDB) HDel(k, f string) + func (db *RedisDB) HGet(k, f string) string + func (db *RedisDB) HIncr(k, f string, delta int) (int, error) + func (db *RedisDB) HIncrfloat(k, f string, delta float64) (float64, error) + func (db *RedisDB) HKeys(key string) ([]string, error) + func (db *RedisDB) HSet(k string, fv ...string) + func (db *RedisDB) HllAdd(k string, elems ...string) (int, error) + func (db *RedisDB) HllCount(keys ...string) (int, error) + func (db *RedisDB) HllMerge(destKey string, sourceKeys ...string) error + func (db *RedisDB) Incr(k string, delta int) (int, error) + func (db *RedisDB) Incrfloat(k string, delta float64) (float64, error) + func (db *RedisDB) IsMember(k, v string) (bool, error) + func (db *RedisDB) Keys() []string + func (db *RedisDB) List(k string) ([]string, error) + func (db *RedisDB) Lpop(k string) (string, error) + func (db *RedisDB) Lpush(k, v string) (int, error) + func (db *RedisDB) Members(k string) ([]string, error) + func (db *RedisDB) Pop(k string) (string, error) + func (db *RedisDB) Push(k string, v ...string) (int, error) + func (db *RedisDB) SRem(k string, fields ...string) (int, error) + func (db *RedisDB) Set(k, v string) error + func (db *RedisDB) SetAdd(k string, elems ...string) (int, error) + func (db *RedisDB) SetTTL(k string, ttl time.Duration) + func (db *RedisDB) SortedSet(k string) (map[string]float64, error) + func (db *RedisDB) Stream(key string) ([]StreamEntry, error) + func (db *RedisDB) TTL(k string) time.Duration + func (db *RedisDB) Type(k string) string + func (db *RedisDB) Unlink(k string) bool + func (db *RedisDB) XAdd(k string, id string, values []string) (string, error) + func (db *RedisDB) ZAdd(k string, score float64, member string) (bool, error) + func (db *RedisDB) ZMScore(k string, members []string) ([]float64, error) + func (db *RedisDB) ZMembers(k string) ([]string, error) + func (db *RedisDB) ZRem(k, member string) (bool, error) + func (db *RedisDB) ZScore(k, member string) (float64, error) + type StreamEntry struct + ID string + Values []string + type Subscriber struct + func (s *Subscriber) Channels() []string + func (s *Subscriber) Close() + func (s *Subscriber) Count() int + func (s *Subscriber) Messages() <-chan PubsubMessage + func (s *Subscriber) Patterns() []string + func (s *Subscriber) Pmessages() <-chan PubsubPmessage + func (s *Subscriber) Psubscribe(pat string) int + func (s *Subscriber) Publish(c, msg string) int + func (s *Subscriber) Punsubscribe(pat string) int + func (s *Subscriber) Subscribe(c string) int + func (s *Subscriber) Unsubscribe(c string) int + type T interface + Errorf func(string, ...interface{}) + Helper func() + type Tester interface + Cleanup func(func()) + Fatalf func(string, ...interface{})
Go to main page