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

Method writeTimeout

writer.go:839–844  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

837}
838
839func (w *Writer) writeTimeout() time.Duration {
840 if w.WriteTimeout > 0 {
841 return w.WriteTimeout
842 }
843 return 10 * time.Second
844}
845
846func (w *Writer) withLogger(do func(Logger)) {
847 if w.Logger != nil {

Callers 2

produceMethod · 0.95
StatsMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected