- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for initRedis (0.65 sec)
-
internal/event/target/redis.go
close(target.quitCh) if target.pool != nil { return target.pool.Close() } return nil } func (target *RedisTarget) init() error { return target.initOnce.Do(target.initRedis) } func (target *RedisTarget) initRedis() error { conn := target.pool.Get() defer conn.Close() _, pingErr := conn.Do("PING") if pingErr != nil { if !(xnet.IsConnRefusedErr(pingErr) || xnet.IsConnResetErr(pingErr)) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 9.1K bytes - Viewed (0)