Versions in this module Expand all Collapse all v1 v1.0.2 Oct 14, 2024 v1.0.1 Sep 29, 2024 Changes in this version + const PrefixKey + type AdapterCache interface + BRPop func(timeout time.Duration, keys ...string) ([]string, 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) + HExists func(hk, key string) (bool, error) + HIncrBy func(key, field string, increment int) (int64, error) + HashDel func(hk, key string) error + HashGet func(hk, key string) (string, error) + HashGetAll func(hk string) (map[string]string, error) + HashSet func(key string, val ...interface{}) error + Increase func(key string) error + LPush func(key string, values ...interface{}) (int64, error) + LRange func(key string, start, stop int64) ([]string, error) + RPop func(key string) (string, error) + RPush func(key string, values ...interface{}) error + ScanKey func(key string) []string + 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 + 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{})
Go to main page