storage

type AdapterCache interface {
	String() string
	Get(key string) (string, error)
	Set(key string, val interface{}, expire int) error
	Del(key string) error
	HashDel(hk, key string) error
	HashGet(hk, key string) (string, error)
	HashSet(hk, key string, val interface{}) error
	HashMGet(hk string, fields ...string) ([]interface{}, error)
	HashMSet(hk string, mapVal map[string]interface{}) error
	Increase(key string) error
	Decrease(key string) error
	Expire(key string, dur time.Duration) error
	SAdd(key string, members ...interface{}) (int64, error)
	SMembers(key string) ([]string, error)
	SIsMember(key string, member string) (bool, error)
	SMove(source, destination string, member interface{}) (bool, error)
	SRem(key string, members ...interface{}) (int64, error)
}

type AdapterLocker interface {
	String() string
	Lock(key string, ttl int64, options *redislock.Options) (*redislock.Lock, error)
}

type AdapterQueue interface {
	String() string
	Append(message Messager) error
	Register(name string, f ConsumerFunc)
	Run()
	Shutdown()
}

type ConsumerFunc func(Messager) error

type Messager interface {
	SetID(string)
	SetStream(string)
	SetValues(map[string]interface{})
	GetID() string
	GetStream() string
	GetValues() map[string]interface{}
	GetPrefix() string
	SetPrefix(string)
}