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

Method Bytes

protocol/record.go:127–127  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

125// through calls to Bytes.
126type bytesBuffer interface {
127 Bytes() []byte
128}
129
130// magicByteOffset is the position of the magic byte in all versions of record

Callers 15

TestMessageCRC32Function · 0.65
TestReaderTruncatedResponseFunction · 0.65
BytesMethod · 0.65
mustCompressFunction · 0.65
TestMessageFixturesFunction · 0.65
readMessageV1Method · 0.65
BenchmarkReadVarIntFunction · 0.65
TestWriteVarIntFunction · 0.65
testWriteOptimizationFunction · 0.65
bytesMethod · 0.65
writeToMethod · 0.65
BenchmarkSyncGroupResponseV0Function · 0.65

Implementers 1

kafkaWriteBufferbuilder_test.go

Calls

no outgoing calls

Tested by 15

TestMessageCRC32Function · 0.52
TestReaderTruncatedResponseFunction · 0.52
BytesMethod · 0.52
mustCompressFunction · 0.52
TestMessageFixturesFunction · 0.52
BenchmarkReadVarIntFunction · 0.52
TestWriteVarIntFunction · 0.52
testWriteOptimizationFunction · 0.52
BenchmarkSyncGroupResponseV0Function · 0.52
TestEncodeDecodeFlexibleTypeFunction · 0.52
TestVarIntsFunction · 0.52
TestFloat64Function · 0.52