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

Function isTemporary

error.go:605–611  ·  view source on GitHub ↗
(err error)

Source from the content-addressed store, hash-verified

603}
604
605func isTemporary(err error) bool {
606 var tempError interface{ Temporary() bool }
607 if errors.As(err, &tempError) {
608 return tempError.Temporary()
609 }
610 return false
611}
612
613func isTransientNetworkError(err error) bool {
614 return errors.Is(err, io.ErrUnexpectedEOF) ||

Callers 2

LookupPartitionMethod · 0.85
writeBatchMethod · 0.85

Calls 1

TemporaryMethod · 0.45

Tested by

no test coverage detected