eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-06-27 10:53:42 +02:00
Code Releases Activity

redis.go: implement functions for pipeline.

Browse source
This commit is contained in:
Henrik Hautakoski 2022-01-20 11:49:13 +01:00
parent 93c9f8a721
commit 90df18562c
No known key found for this signature in database
GPG key ID: 608414D93E862CCD
1 changed files with 12 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

12
redis.go
View file

@ -10,6 +10,8 @@ import (
var rdb *redis.Client var rdb *redis.Client
var redis_pipe redis.Pipeliner
var redisCtx = context.Background() var redisCtx = context.Background()
var redisPrefix = "ship." var redisPrefix = "ship."
@ -20,6 +22,8 @@ func RedisConnect(addr string, password string, db int) {
Password: password, Password: password,
DB: db, DB: db,
}) })
redis_pipe = rdb.Pipeline()
} }
func RedisKey(components ...string) (string) { func RedisKey(components ...string) (string) {
@ -37,3 +41,11 @@ func RedisSet(key string, value interface{}, expiration time.Duration) (*redis.S
func RedisPublish(channel string, message interface{}) (*redis.IntCmd) { func RedisPublish(channel string, message interface{}) (*redis.IntCmd) {
return rdb.Publish(redisCtx, channel, message) return rdb.Publish(redisCtx, channel, message)
} }
func RedisRegisterPublish(channel string, message interface{}) (*redis.IntCmd) {
return redis_pipe.Publish(redisCtx, channel, message)
}
func RedisSend() ([]redis.Cmder, error) {
return redis_pipe.Exec(redisCtx)
}