59643b6a0a
- Rename Ctx to RedisCtx with CancelRedisCtx function - Signal handler now cancels context before closing Redis
35 lines
949 B
Go
35 lines
949 B
Go
package misc
|
|
|
|
import (
|
|
"context"
|
|
"os"
|
|
"sync"
|
|
|
|
"github.com/go-redis/redis/v8"
|
|
)
|
|
|
|
// Config - это у нас глобальная штука.
|
|
var Config myConfig
|
|
|
|
// To break circular message forwarding we must set some sane default, it can be overridden via config.
|
|
var ForwardMax int64 = 5
|
|
|
|
// Объектики клиента-редиски.
|
|
var RedisClient *redis.Client
|
|
var Subscriber *redis.PubSub
|
|
|
|
// Канал, в который приходят уведомления для хэндлера сигналов от траппера сигналов.
|
|
var SigChan = make(chan os.Signal, 1)
|
|
|
|
// RedisCtx - контекст для операций с редиской. Отменяется при завершении.
|
|
var RedisCtx context.Context
|
|
var CancelRedisCtx context.CancelFunc
|
|
|
|
var once sync.Once
|
|
|
|
func init() {
|
|
RedisCtx, CancelRedisCtx = context.WithCancel(context.Background())
|
|
}
|
|
|
|
/* vim: set ft=go noet ai ts=4 sw=4 sts=4: */
|