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

Method writeBackoffMax

writer.go:804–809  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

802}
803
804func (w *Writer) writeBackoffMax() time.Duration {
805 if w.WriteBackoffMax > 0 {
806 return w.WriteBackoffMax
807 }
808 return 1 * time.Second
809}
810
811func (w *Writer) batchSize() int {
812 if w.BatchSize > 0 {

Callers 3

testWriterDefaultsFunction · 0.95
StatsMethod · 0.95
writeBatchMethod · 0.80

Calls

no outgoing calls

Tested by 1

testWriterDefaultsFunction · 0.76