- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for IsConnResetErr (0.08 sec)
-
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) -
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) -
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) -
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) -
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)