MCPcopy
hub / github.com/segmentio/kafka-go / isTransientNetworkError

Function isTransientNetworkError

error.go:613–618  ·  view source on GitHub ↗
(err error)

Source from the content-addressed store, hash-verified

611}
612
613func isTransientNetworkError(err error) bool {
614 return errors.Is(err, io.ErrUnexpectedEOF) ||
615 errors.Is(err, syscall.ECONNREFUSED) ||
616 errors.Is(err, syscall.ECONNRESET) ||
617 errors.Is(err, syscall.EPIPE)
618}
619
620func silentEOF(err error) error {
621 if errors.Is(err, io.EOF) {

Callers 1

writeBatchMethod · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected