Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for initRedis (0.05 sec)

  1. 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)
Back to top