storage

May 24, 2022

Changes in this version

type AdapterCache

+ HashSet func(key string, val interface{}) error

May 24, 2022

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

+ 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{})