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

Method readTimeout

writer.go:832–837  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

830}
831
832func (w *Writer) readTimeout() time.Duration {
833 if w.ReadTimeout > 0 {
834 return w.ReadTimeout
835 }
836 return 10 * time.Second
837}
838
839func (w *Writer) writeTimeout() time.Duration {
840 if w.WriteTimeout > 0 {

Callers 2

partitionsMethod · 0.95
StatsMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected