- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for initRedis (0.81 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)) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0)