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

Method stats

writer.go:860–869  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

858}
859
860func (w *Writer) stats() *writerStats {
861 w.once.Do(func() {
862 // This field is not nil when the writer was constructed with NewWriter
863 // to share the value with the dial function and count dials.
864 if w.writerStats == nil {
865 w.writerStats = new(writerStats)
866 }
867 })
868 return w.writerStats
869}
870
871// Stats returns a snapshot of the writer stats since the last time the method
872// was called, or since the writer was created if it is called for the first

Callers 3

StatsMethod · 0.95
awaitBatchMethod · 0.80
writeBatchMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected