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

Method Len

protocol/buffer.go:27–27  ·  view source on GitHub ↗

Returns the number of bytes remaining to be read from the payload.

()

Source from the content-addressed store, hash-verified

25 io.ReadCloser
26 // Returns the number of bytes remaining to be read from the payload.
27 Len() int
28}
29
30// NewBytes constructs a Bytes value from b.

Callers 15

TestMemberMetadataFunction · 0.65
TestJoinGroupResponseFunction · 0.65
TestProtocolFunction · 0.65
TestMessageSetReaderFunction · 0.65
readMessageV1Method · 0.65
readMessageV2Method · 0.65
TestCreateTopicsResponseFunction · 0.65

Implementers 4

fetchResponseBuilderbuilder_test.go
pageprotocol/buffer.go
pageBufferprotocol/buffer.go
pageRefprotocol/buffer.go

Calls

no outgoing calls

Tested by 15

TestMemberMetadataFunction · 0.52
TestJoinGroupResponseFunction · 0.52
TestProtocolFunction · 0.52
TestMessageSetReaderFunction · 0.52
TestCreateTopicsResponseFunction · 0.52
TestReadStringArrayFunction · 0.52
TestReadMapStringInt32Function · 0.52