cache

Documentation

Index

• func InitMemory() error
• func InitRedis() error
• type Adapter
• type Message

Functions

func InitMemory

func InitMemory() error

func InitRedis

func InitRedis() error

Types

type Adapter

type Adapter interface {
	Connect() error
	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
	Decrease(key string) error
	Expire(key string, dur time.Duration) error
	cache.AdapterQueue
}

var MemoryAdapter Adapter

var RedisAdapter Adapter

type Message

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