miniredis

May 31, 2023

Changes in this version

type Miniredis

+ func (m *Miniredis) ZMScore(k string, members ...string) ([]float64, error)

type RedisDB

+ func (db *RedisDB) ZMScore(k string, members []string) ([]float64, error)

Jun 29, 2022

Changes in this version

+ var DumpMaxLineLen = 60

Jan 19, 2022

Changes in this version

type Miniredis

+ func (m *Miniredis) Copy(srcDB int, src string, destDB int, dest string) error

Dec 12, 2021

Changes in this version

type Miniredis

+ func RunT(t Tester) *Miniredis

+ type Tester interface

+ Cleanup func(func())

+ Fatalf func(string, ...interface{})

Jun 23, 2021

Changes in this version

+ var ErrNotValidHllValue = errors.New(msgNotValidHllValue)

type Miniredis

+ 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

type RedisDB

+ 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

Sep 16, 2020

Changes in this version

type T

+ Errorf func(string, ...interface{})

+ Helper func()

Jul 15, 2020

Changes in this version

type Miniredis

+ func (m *Miniredis) RequireUserAuth(username, pw string)

Jun 24, 2020

Changes in this version

type Miniredis

+ func RunTLS(cfg *tls.Config) (*Miniredis, error)

+ func (m *Miniredis) SetError(msg string)

+ func (m *Miniredis) StartTLS(cfg *tls.Config) error

Mar 4, 2020

Changes in this version

type Miniredis

+ func (m *Miniredis) Touch(k string)

type RedisDB

+ func (db *RedisDB) Touch(k string)

Dec 18, 2019

Changes in this version

type Miniredis

+ Ctx context.Context

+ CtxCancel context.CancelFunc

Nov 20, 2019

Changes in this version

type Miniredis

+ func (m *Miniredis) Stream(k string) ([]StreamEntry, error)

+ func (m *Miniredis) XAdd(k string, id string, values []string) (string, error)

type RedisDB

+ func (db *RedisDB) Stream(k string) ([]StreamEntry, error)

+ func (db *RedisDB) XAdd(k string, id string, values []string) (string, error)

+ type StreamEntry struct

+ ID string

+ Values []string

Oct 23, 2019

Changes in this version

type Miniredis

+ func (m *Miniredis) Server() *server.Server

Sep 18, 2019

Changes in this version

type Miniredis

+ 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) IncrByFloat(k string, delta float64) (float64, error)

+ func (m *Miniredis) RPop(k string) (string, error)

+ func (m *Miniredis) RPush(k string, v ...string) (int, 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) Unlink(k string) bool

type RedisDB

+ func (db *RedisDB) Unlink(k string) bool

Jul 24, 2019

Changes in this version

type Miniredis

+ func (m *Miniredis) Seed(seed int)

+ type PubsubPmessage struct

+ Channel string

+ Message string

+ Pattern string

type Subscriber

+ func (s *Subscriber) Pmessages() <-chan PubsubPmessage

May 9, 2019

Changes in this version

+ var ErrFloatValueError = errors.New(msgInvalidFloat)

+ var ErrIntValueError = errors.New(msgInvalidInt)

+ var ErrKeyNotFound = errors.New(msgKeyNotFound)

+ var ErrWrongType = errors.New(msgWrongType)

+ type Miniredis struct

+ func NewMiniRedis() *Miniredis

+ func Run() (*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) 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) HIncrfloat(k, f string, delta float64) (float64, error)

+ func (m *Miniredis) HKeys(k string) ([]string, error)

+ func (m *Miniredis) HSet(k, f, v string)

+ func (m *Miniredis) Host() string

+ func (m *Miniredis) Incr(k string, delta int) (int, 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) 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) RequireAuth(pw string)

+ func (m *Miniredis) Restart() error

+ func (m *Miniredis) SRem(k string, fields ...string) (int, error)

+ func (m *Miniredis) Select(i int)

+ func (m *Miniredis) Set(k, v string) error

+ func (m *Miniredis) SetAdd(k string, elems ...string) (int, error)

+ 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) 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) ZAdd(k string, score float64, member string) (bool, 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 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, f, v string)

+ 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) TTL(k string) time.Duration

+ func (db *RedisDB) Type(k string) string

+ func (db *RedisDB) ZAdd(k string, score float64, member string) (bool, 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 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) 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

+ Fail func()