Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for IsConnResetErr (0.09 sec)

  1. internal/event/target/nsq.go

    		return err
    	}
    	target.producer = producer
    
    	err = target.producer.Ping()
    	if err != nil {
    		// To treat "connection refused" errors as errNotConnected.
    		if !(xnet.IsConnRefusedErr(err) || xnet.IsConnResetErr(err)) {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    		}
    		target.producer.Stop()
    		return err
    	}
    
    	yes, err := target.isActive()
    	if err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  2. internal/event/target/postgresql.go

    		// Set the maximum connections limit
    		target.db.SetMaxOpenConns(args.MaxOpenConnections)
    	}
    
    	err = target.db.Ping()
    	if err != nil {
    		if !(xnet.IsConnRefusedErr(err) || xnet.IsConnResetErr(err)) {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    		}
    	} else {
    		if err = target.executeStmts(); err != nil {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  3. internal/event/target/redis.go

    }
    
    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)) {
    			target.loggerOnce(context.Background(), pingErr, target.ID().String())
    		}
    		return pingErr
    	}
    
    	if err := target.args.validateFormat(conn); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  4. internal/event/target/mysql.go

    		// Set the maximum connections limit
    		target.db.SetMaxOpenConns(args.MaxOpenConnections)
    	}
    
    	err = target.db.Ping()
    	if err != nil {
    		if !(xnet.IsConnRefusedErr(err) || xnet.IsConnResetErr(err)) {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    		}
    	} else {
    		if err = target.executeStmts(); err != nil {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  5. internal/event/target/amqp.go

    	return target.initOnce.Do(target.initAMQP)
    }
    
    func (target *AMQPTarget) initAMQP() error {
    	conn, err := amqp091.Dial(target.args.URL.String())
    	if err != nil {
    		if xnet.IsConnRefusedErr(err) || xnet.IsConnResetErr(err) {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    		}
    		return err
    	}
    	target.conn = conn
    
    	return nil
    }
    
    // NewAMQPTarget - creates new AMQP target.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
Back to top