diff --git a/pkg/cache/type.go b/pkg/cache/type.go new file mode 100644 index 00000000..5327760e --- /dev/null +++ b/pkg/cache/type.go @@ -0,0 +1,24 @@ +package cache + +import ( + "time" +) + +type Adapter interface { + Connect() + Get(key string) (string, error) + Set(key string, val interface{}, expire int) error + Del(key string) error + HashGet(hk, key string) (string, error) + HashDel(hk, key string) error + Increase(key string) error + Expire(key string, dur time.Duration) error + SetQueue(name string, message Message) error + GetQueue(name string, f func(message Message) error) +} + +type Message struct { + ID string + Stream string + Values map[string]interface{} +}