cache

Mar 25, 2021

Changes in this version

type Adapter

+ String func() string

type Memory

+ func (*Memory) String() string

type MemoryMessage

+ func (m *MemoryMessage) GetPrefix() (prefix string)

+ func (m *MemoryMessage) SetPrefix(prefix string)

type Message

+ GetPrefix func() string

+ SetPrefix func(string)

type Redis

+ func (*Redis) String() string

type RedisMessage

+ func (m *RedisMessage) GetPrefix() (prefix string)

+ func (m *RedisMessage) SetPrefix(prefix string)

Mar 24, 2021

Changes in this version

type Adapter

+ SetPrefix func(string)

+ type AdapterLocker interface

+ Lock func(key string, ttl int64, options *redislock.Options) (*redislock.Lock, error)

type Memory

+ func (m *Memory) Lock(_ string, _ int64, _ *redislock.Options) (*redislock.Lock, error)

+ func (r *Memory) SetPrefix(string)

type Redis

+ func (r *Redis) SetPrefix(string)

Oct 10, 2020

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

+ type AdapterQueue interface

+ Append func(name string, message Message) error

+ Register func(name string, f ConsumerFunc)

+ Run func()

+ Shutdown func()

+ type ConsumerFunc func(Message) error

+ type Memory struct

+ PoolNum uint

+ func (m *Memory) Append(name string, 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) Register(name string, f ConsumerFunc)

+ func (m *Memory) Run()

+ func (m *Memory) Set(key string, val interface{}, expire int) error

+ func (m *Memory) Shutdown()

+ type MemoryMessage struct

+ func (m *MemoryMessage) GetID() string

+ func (m *MemoryMessage) GetStream() string

+ func (m *MemoryMessage) GetValues() map[string]interface{}

+ func (m *MemoryMessage) SetID(id string)

+ func (m *MemoryMessage) SetStream(stream string)

+ func (m *MemoryMessage) SetValues(values map[string]interface{})

+ type Message interface

+ GetID func() string

+ GetStream func() string

+ GetValues func() map[string]interface{}

+ SetID func(string)

+ SetStream func(string)

+ SetValues func(map[string]interface{})

+ type Redis struct

+ ConnectOption *redis.Options

+ ConsumerOptions *redisqueue.ConsumerOptions

+ ProducerOptions *redisqueue.ProducerOptions

+ func (r *Redis) Append(name string, 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) Shutdown()

+ type RedisMessage struct

+ func (m *RedisMessage) GetID() string

+ func (m *RedisMessage) GetStream() string

+ func (m *RedisMessage) GetValues() map[string]interface{}

+ func (m *RedisMessage) SetID(id string)

+ func (m *RedisMessage) SetStream(stream string)

+ func (m *RedisMessage) SetValues(values map[string]interface{})