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

Function acquireBuffer

buffer.go:18–20  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

16}
17
18func acquireBuffer() *bytes.Buffer {
19 return bufferPool.Get().(*bytes.Buffer)
20}
21
22func releaseBuffer(b *bytes.Buffer) {
23 if b != nil {

Callers 3

newMessageSetReaderFunction · 0.85
compressRecordBatchFunction · 0.85
compressMessageSetFunction · 0.85

Calls 1

GetMethod · 0.80

Tested by

no test coverage detected