Versions in this module Expand all Collapse all v1 v1.0.0 Dec 9, 2017 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 RediQueue struct + func NewRediQueue() *RediQueue + func Run(bgsave bool) (*RediQueue, error) + func RunAddr(addr string, saveDuration int) (*RediQueue, error) + func (m *RediQueue) Addr() string + func (m *RediQueue) CheckList(t T, key string, expected ...string) + func (m *RediQueue) CheckSet(t T, key string, expected ...string) + func (m *RediQueue) Close() + func (m *RediQueue) CommandCount() int + func (m *RediQueue) CurrentConnectionCount() int + func (m *RediQueue) DB(i int) *RedisDB + func (m *RediQueue) Del(k string) bool + func (m *RediQueue) Dump() string + func (m *RediQueue) Exists(k string) bool + func (m *RediQueue) FlushAll() + func (m *RediQueue) FlushDB() + func (m *RediQueue) Host() string + func (m *RediQueue) IsMember(k, v string) (bool, error) + func (m *RediQueue) Keys() []string + func (m *RediQueue) List(k string) ([]string, error) + func (m *RediQueue) Load() + func (m *RediQueue) Lpop(k string) (string, error) + func (m *RediQueue) Lpush(k, v string) (int, error) + func (m *RediQueue) Members(k string) ([]string, error) + func (m *RediQueue) Pop(k string) (string, error) + func (m *RediQueue) Port() string + func (m *RediQueue) Push(k string, v ...string) (int, error) + func (m *RediQueue) RequireAuth(pw string) + func (m *RediQueue) Restart() error + func (m *RediQueue) SRem(k string, fields ...string) (int, error) + func (m *RediQueue) Save() + func (m *RediQueue) Select(i int) + func (m *RediQueue) SetAdd(k string, elems ...string) (int, error) + func (m *RediQueue) SetTime(t time.Time) + func (m *RediQueue) Start() error + func (m *RediQueue) StartAddr(addr string) error + func (m *RediQueue) TotalConnectionCount() int + func (m *RediQueue) Type(k string) 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) 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) SetAdd(k string, elems ...string) (int, error) + func (db *RedisDB) Type(k string) string + type T interface + Fail func()