- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for IsConnRefusedErr (0.21 sec)
-
internal/event/target/redis.go
defer conn.Close() _, pingErr := conn.Do("PING") if pingErr != nil { if xnet.IsConnRefusedErr(pingErr) { return store.ErrNotConnected } return pingErr } if !target.firstPing { if err := target.args.validateFormat(conn); err != nil { if xnet.IsConnRefusedErr(err) { return store.ErrNotConnected } return err } target.firstPing = true }
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) -
internal/event/target/nsq.go
if err != nil { return false, err } target.producer = producer } if err := target.producer.Ping(); err != nil { // To treat "connection refused" errors as errNotConnected. if xnet.IsConnRefusedErr(err) { return false, store.ErrNotConnected } return false, err } return true, nil } // Save - saves the events to the store which will be replayed when the nsq connection is active.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 7.1K bytes - Viewed (0)