Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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
18
func
acquireBuffer() *bytes.Buffer {
19
return
bufferPool.Get().(*bytes.Buffer)
20
}
21
22
func
releaseBuffer(b *bytes.Buffer) {
23
if
b != nil {
Callers
3
newMessageSetReader
Function · 0.85
compressRecordBatch
Function · 0.85
compressMessageSet
Function · 0.85
Calls
1
Get
Method · 0.80
Tested by
no test coverage detected