Versions in this module Expand all Collapse all v0 v0.0.1 Mar 2, 2024 Changes in this version + type BitMap interface + ClearAll func(id any) error + GetAll func(id any) ([]byte, error) + GetAllToBinary func(id any) (string, error) + GetIndex func(id any, index uint) (bool, error) + RedisClient func() *redis.Client + SetIndex func(id any, index uint, status bool) error + TopicKey func(id any) string + func NewBitMap(client *redis.Client, topic string) BitMap + type MapInt64 interface + ClearAll func() error + Count func() (int64, error) + Del func(key string) error + Dels func(key []string) error + Get func(key string) (int64, error) + GetAll func() (map[string]int64, error) + Gets func(keys []string) (map[string]int64, error) + RedisClient func() *redis.Client + Scan func(dest interface{}) error + Set func(key string, value int64) error + Sets func(kv map[string]int64) error + TopicKey func() string + func NewMapInt64(client *redis.Client, topic string) MapInt64 + type MapInt64List interface + ClearAll func(id any) error + Count func(id any) (int64, error) + Del func(id any, key string) error + Dels func(id any, key []string) error + Get func(id any, key string) (int64, error) + GetAll func(id any) (map[string]int64, error) + Gets func(id any, keys []string) (map[string]int64, error) + RedisClient func() *redis.Client + Scan func(id any, dest interface{}) error + Set func(id any, key string, value int64) error + Sets func(id any, kv map[string]int64) error + TopicKey func(id any) string + func NewMapInt64List(client *redis.Client, topic string) MapInt64List + type MapLimit interface + Add func(key string, delta uint) error + ClearAll func() error + Count func() (int64, error) + Del func(key string) error + Get func(key string) (int64, error) + GetAll func() (map[string]int64, error) + GetAndAdd func(key string, delta uint) (int64, error) + GetAndSub func(key string, delta uint) (int64, error) + IsExist func(key string) (bool, error) + IsToLimit func(key string, max int64) bool + RedisClient func() *redis.Client + Reset func(key string) error + Scan func(dest interface{}) error + Set func(key string, value uint) error + SetNX func(key string, value uint) error + Sub func(key string, delta uint) error + TopicKey func() string + func NewLimit(client *redis.Client, topic string) MapLimit + type MapLimitList interface + Add func(id any, key string, delta uint) error + ClearAll func(id any) error + Count func(id any) (int64, error) + Del func(id any, key string) error + Get func(id any, key string) (int64, error) + GetAll func(id any) (map[string]int64, error) + GetAndAdd func(id any, key string, delta uint) (int64, error) + GetAndSub func(id any, key string, delta uint) (int64, error) + IsExist func(id any, key string) (bool, error) + IsToLimit func(id any, key string, max int64) bool + RedisClient func() *redis.Client + Reset func(id any, key string) error + Scan func(id any, dest interface{}) error + Set func(id any, key string, value uint) error + SetNX func(id any, key string, value uint) error + Sub func(id any, key string, delta uint) error + TopicKey func(id any) string + func NewLimitList(client *redis.Client, topic string) MapLimitList + type MapString interface + ClearAll func() error + Count func() (int64, error) + Del func(key string) error + Dels func(key []string) error + Get func(key string) (string, error) + GetAll func() (map[string]string, error) + GetJson func(key string, pointer any) error + Gets func(keys []string) (map[string]string, error) + RedisClient func() *redis.Client + Scan func(dest interface{}) error + Set func(key string, value string) error + SetJson func(key string, pointer any) error + Sets func(kv map[string]string) error + TopicKey func() string + func NewMapString(client *redis.Client, topic string) MapString + type MapStringList interface + ClearAll func(id any) error + Count func(id any) (int64, error) + Del func(id any, key string) error + Dels func(id any, key []string) error + Get func(id any, key string) (string, error) + GetAll func(id any) (map[string]string, error) + GetJson func(id any, key string, pointer any) error + Gets func(id any, keys []string) (map[string]string, error) + RedisClient func() *redis.Client + Scan func(id any, dest interface{}) error + Set func(id any, key string, value string) error + SetJson func(id any, key string, pointer any) error + Sets func(id any, kv map[string]string) error + TopicKey func(id any) string + func NewMapStringList(client *redis.Client, topic string) MapStringList + type QueueInt64 interface + ClearAll func() error + Count func() (int64, error) + GetAll func() ([]int64, error) + LPop func() (int64, error) + LPopList func(count int) ([]int64, error) + LPush func(value int64) error + LPushList func(list []int64) error + RPop func() (int64, error) + RPopList func(count int) ([]int64, error) + RPush func(value int64) error + RPushList func(list []int64) error + RedisClient func() *redis.Client + SetQueueInt64MaxLength func(max uint64) + TopicKey func() string + func NewQueueInt64(client *redis.Client, topic string) QueueInt64 + func NewQueueInt64AndMax(client *redis.Client, topic string, max uint64) QueueInt64 + type QueueInt64List interface + ClearAll func(id any) error + Count func(id any) (int64, error) + GetAll func(id any) ([]int64, error) + LPop func(id any) (int64, error) + LPopList func(id any, count int) ([]int64, error) + LPush func(id any, value int64) error + LPushList func(id any, list []int64) error + RPop func(id any) (int64, error) + RPopList func(id any, count int) ([]int64, error) + RPush func(id any, value int64) error + RPushList func(id any, list []int64) error + RedisClient func() *redis.Client + SetQueueInt64ListMaxLength func(max uint64) + TopicKey func(id any) string + func NewQueueInt64List(client *redis.Client, topic string) QueueInt64List + func NewQueueInt64ListAndMax(client *redis.Client, topic string, max uint64) QueueInt64List + type QueueString interface + ClearAll func() error + Count func() (int64, error) + GetAll func() ([]string, error) + LPop func() (string, error) + LPopList func(count int) ([]string, error) + LPush func(value string) error + LPushList func(list []string) error + RPop func() (string, error) + RPopList func(count int) ([]string, error) + RPush func(value string) error + RPushList func(list []string) error + RedisClient func() *redis.Client + SetQueueStringMaxLength func(max uint64) + TopicKey func() string + func NewQueueString(client *redis.Client, topic string) QueueString + func NewQueueStringAndMax(client *redis.Client, topic string, max uint64) QueueString + type QueueStringList interface + ClearAll func(id any) error + Count func(id any) (int64, error) + GetAll func(id any) ([]string, error) + LPop func(id any) (string, error) + LPopList func(id any, count int) ([]string, error) + LPush func(id any, value string) error + LPushList func(id any, list []string) error + RPop func(id any) (string, error) + RPopList func(id any, count int) ([]string, error) + RPush func(id any, value string) error + RPushList func(id any, list []string) error + RedisClient func() *redis.Client + SetQueueStringListMaxLength func(max uint64) + TopicKey func(id any) string + func NewQueueStringList(client *redis.Client, topic string) QueueStringList + func NewQueueStringListAndMax(client *redis.Client, topic string, max uint64) QueueStringList + type Set interface + Add func(key string) error + Adds func(keys []string) error + ClearAll func() error + Count func() (int64, error) + Del func(key string) error + Dels func(keys []string) error + GetAllKey func() ([]string, error) + GetRandKeys func(limit uint) ([]string, error) + IsExist func(key string) (bool, error) + RedisClient func() *redis.Client + Spop func(limit uint) ([]string, error) + SpopAll func() ([]string, error) + SpopOne func() (string, error) + TopicKey func() string + func NewSet(client *redis.Client, topic string) Set + type SetList interface + Add func(id any, value string) error + Adds func(id any, keys []string) error + ClearAll func(id any) error + Count func(id any) (int64, error) + Del func(id any, key string) error + Dels func(id any, keys []string) error + GetAllKey func(id any) ([]string, error) + GetRandKeys func(id any, limit uint) ([]string, error) + IsExist func(id any, key string) (bool, error) + RedisClient func() *redis.Client + Spop func(id any, limit uint) ([]string, error) + SpopAll func(id any) ([]string, error) + SpopOne func(id any) (string, error) + TopicKey func(id any) string + func NewSetList(client *redis.Client, topic string) SetList + type ZSet interface + Add func(key string, score float64) error + Adds func(keys map[string]float64) error + ClearAll func() error + Count func() (int64, error) + Del func(key string) error + Dels func(keys []string) error + GetAllKey func() ([]ZsetItem, error) + GetByIndex func(index int64) (ZsetItem, error) + GetByIndexDESC func(index int64) (ZsetItem, error) + GetByIndexRange func(start int64, end int64) ([]ZsetItem, error) + GetByIndexRangeDESC func(start int64, end int64) ([]ZsetItem, error) + GetByKey func(key string) (ZsetItem, error) + RedisClient func() *redis.Client + TopicKey func() string + ZpopMax func() (ZsetItem, error) + ZpopMin func() (ZsetItem, error) + func NewZSet(client *redis.Client, topic string) ZSet + type ZSetList interface + Add func(id any, key string, score float64) error + Adds func(id any, keys map[string]float64) error + ClearAll func(id any) error + Count func(id any) (int64, error) + Del func(id any, key string) error + Dels func(id any, keys []string) error + GetAllKey func(id any) ([]ZsetItem, error) + GetByIndex func(id any, index int64) (ZsetItem, error) + GetByIndexDESC func(id any, index int64) (ZsetItem, error) + GetByIndexRange func(id any, start int64, end int64) ([]ZsetItem, error) + GetByIndexRangeDESC func(id any, start int64, end int64) ([]ZsetItem, error) + GetByKey func(id any, key string) (ZsetItem, error) + RedisClient func() *redis.Client + TopicKey func(id any) string + ZpopMax func(id any) (ZsetItem, error) + ZpopMin func(id any) (ZsetItem, error) + func NewZSetList(client *redis.Client, topic string) ZSetList + type ZsetItem struct + Key string + Score float64