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

Function releaseBuffer

buffer.go:22–27  ·  view source on GitHub ↗
(b *bytes.Buffer)

Source from the content-addressed store, hash-verified

20}
21
22func releaseBuffer(b *bytes.Buffer) {
23 if b != nil {
24 b.Reset()
25 bufferPool.Put(b)
26 }
27}

Callers 5

closeMethod · 0.85
compressRecordBatchFunction · 0.85
writeToMethod · 0.85
writeProduceRequestV2Method · 0.85
compressMessageSetFunction · 0.85

Calls 2

PutMethod · 0.80
ResetMethod · 0.45

Tested by

no test coverage detected