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

Struct kafkaWriteBuffer

builder_test.go:226–229  ·  view source on GitHub ↗

kafkaWriteBuffer is a write buffer that helps writing fetch responses.

Source from the content-addressed store, hash-verified

224
225// kafkaWriteBuffer is a write buffer that helps writing fetch responses.
226type kafkaWriteBuffer struct {
227 writeBuffer
228 buf bytes.Buffer
229}
230
231func newWB() *kafkaWriteBuffer {
232 res := kafkaWriteBuffer{}

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected