Versions in this module Expand all Collapse all v1 v1.0.0 Nov 9, 2023 Changes in this version + const PrefixKey + type AdapterCache interface + 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 + String func() string + type AdapterLocker interface + Lock func(key string, ttl int64, options *redislock.Options) (*redislock.Lock, error) + String func() string + type AdapterQueue interface + Append func(message Messager) error + Register func(name string, f ConsumerFunc) + Run func() + Shutdown func() + String func() string + type ConsumerFunc func(Messager) error + type Messager interface + GetErrorCount func() int + GetID func() string + GetPrefix func() string + GetStream func() string + GetValues func() map[string]interface{} + SetErrorCount func(count int) + SetID func(string) + SetPrefix func(string) + SetStream func(string) + SetValues func(map[string]interface{})
Go to main page