Versions in this module Expand all Collapse all v1 v1.0.2 Dec 6, 2021 v1.0.0 Nov 28, 2021 Changes in this version + type Adapter interface + Connect func() error + Decrease func(key string) error + Del func(key string) error + Expire func(key string, dur time.Duration) error + Get func(key string) (string, error) + HashDel func(hk, key string) error + HashGet func(hk, key string) (string, error) + Increase func(key string) error + Set func(key string, val interface{}, expire int) error + SetPrefix func(string) + String func() string + type AdapterLocker interface + Lock func(key string, ttl int64, options *redislock.Options) (*redislock.Lock, error) + type AdapterQueue interface + Append func(message Message) error + Register func(name string, f ConsumerFunc) + Run func() + Shutdown func() + type ConsumerFunc func(Message) error + type Memory struct + PoolNum uint + func (*Memory) String() string + func (m *Memory) Append(message Message) error + func (m *Memory) Connect() error + func (m *Memory) Decrease(key string) error + func (m *Memory) Del(key string) error + func (m *Memory) Expire(key string, dur time.Duration) error + func (m *Memory) Get(key string) (string, error) + func (m *Memory) HashDel(hk, key string) error + func (m *Memory) HashGet(hk, key string) (string, error) + func (m *Memory) Increase(key string) error + func (m *Memory) Lock(_ string, _ int64, _ *redislock.Options) (*redislock.Lock, error) + func (m *Memory) Register(name string, f ConsumerFunc) + func (m *Memory) Run() + func (m *Memory) Set(key string, val interface{}, expire int) error + func (m *Memory) Shutdown() + func (r *Memory) SetPrefix(string) + type MemoryMessage struct + func (m *MemoryMessage) GetID() string + func (m *MemoryMessage) GetPrefix() (prefix string) + func (m *MemoryMessage) GetStream() string + func (m *MemoryMessage) GetValues() map[string]interface{} + func (m *MemoryMessage) SetID(id string) + func (m *MemoryMessage) SetPrefix(prefix string) + func (m *MemoryMessage) SetStream(stream string) + func (m *MemoryMessage) SetValues(values map[string]interface{}) + type Message interface + GetID func() string + GetPrefix func() string + GetStream func() string + GetValues func() map[string]interface{} + SetID func(string) + SetPrefix func(string) + SetStream func(string) + SetValues func(map[string]interface{}) + type Redis struct + ConnectOption *redis.Options + ConsumerOptions *redisqueue.ConsumerOptions + ProducerOptions *redisqueue.ProducerOptions + func (*Redis) String() string + func (r *Redis) Append(message Message) error + func (r *Redis) Connect() error + func (r *Redis) Decrease(key string) error + func (r *Redis) Del(key string) error + func (r *Redis) Expire(key string, dur time.Duration) error + func (r *Redis) Get(key string) (string, error) + func (r *Redis) GetClient() *redis.Client + func (r *Redis) HashDel(hk, key string) error + func (r *Redis) HashGet(hk, key string) (string, error) + func (r *Redis) Increase(key string) error + func (r *Redis) Lock(key string, ttl int64, options *redislock.Options) (*redislock.Lock, error) + func (r *Redis) Register(name string, f ConsumerFunc) + func (r *Redis) Run() + func (r *Redis) Set(key string, val interface{}, expire int) error + func (r *Redis) SetPrefix(string) + func (r *Redis) Shutdown() + type RedisMessage struct + func (m *RedisMessage) GetID() string + func (m *RedisMessage) GetPrefix() (prefix string) + func (m *RedisMessage) GetStream() string + func (m *RedisMessage) GetValues() map[string]interface{} + func (m *RedisMessage) SetID(id string) + func (m *RedisMessage) SetPrefix(prefix string) + func (m *RedisMessage) SetStream(stream string) + func (m *RedisMessage) SetValues(values map[string]interface{})