Documentation ¶
Index ¶
- Variables
- func CloseRedis()
- func DelKey(key string) error
- func GET(key string) int64
- func HDEL(keys []interface{}) (int64, error)
- func HKEYS(key string) ([]string, error)
- func HSET(key string, field interface{}, value interface{}) (int64, error)
- func HasKey(key string) bool
- func INCR(key string) int
- func InitRedis(r RedisSection)
- func PingRedis(c redis.Conn, t time.Time) error
- func Pop(count int, queue string) []*dataobj.Message
- func PopEvent(count int, queues []interface{}) []*models.Event
- func Push(event *dataobj.Event) error
- func Set(key string, value interface{}) error
- func SetWithTTL(key string, value interface{}, ttl int) error
- func Write(data *dataobj.Message, queue string) error
- type RedisSection
Constants ¶
This section is empty.
Variables ¶
View Source
var RedisConnPool *redis.Pool
Functions ¶
func CloseRedis ¶
func CloseRedis()
func InitRedis ¶
func InitRedis(r RedisSection)
func SetWithTTL ¶
Types ¶
type RedisSection ¶
type RedisSection struct {
Local localRedis `yaml:"local"`
}
Click to show internal directories.
Click to hide internal directories.