redisc

func CloseRedis ¶

func CloseRedis()

func DelKey ¶

func DelKey(key string) error

func GET ¶

func GET(key string) int64

func HDEL ¶

func HDEL(keys []interface{}) (int64, error)

func HKEYS ¶

func HKEYS(key string) ([]string, error)

func HSET ¶

func HSET(key string, field interface{}, value interface{}) (int64, error)

func HasKey ¶

func HasKey(key string) bool

func INCR ¶

func INCR(key string) int

func InitRedis ¶

func InitRedis(r RedisSection)

func PingRedis ¶

func PingRedis(c redis.Conn, t time.Time) error

func Pop ¶

func Pop(count int, queue string) []*dataobj.Message

func PopEvent ¶ added in v4.0.4

func PopEvent(count int, queues []interface{}) []*models.Event

func Push ¶

func Push(event *dataobj.Event) error

func Set ¶

func Set(key string, value interface{}) error

func SetWithTTL ¶

func SetWithTTL(key string, value interface{}, ttl int) error

func Write ¶

func Write(data *dataobj.Message, queue string) error

Write LPUSH message to redis