Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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
TestMemberMetadata
Function · 0.65
TestJoinGroupResponse
Function · 0.65
TestProtocol
Function · 0.65
TestSASLAuthenticateRequestV0
Function · 0.65
TestSASLAuthenticateResponseV0
Function · 0.65
TestOffsetFetchResponseV1
Function · 0.65
TestMessageSetReader
Function · 0.65
readMessageV1
Method · 0.65
readMessageV2
Method · 0.65
TestCreateTopicsResponse
Function · 0.65
TestDeleteTopicsResponseV1
Function · 0.65
TestOffsetCommitResponseV2
Function · 0.65
Implementers
4
fetchResponseBuilder
builder_test.go
page
protocol/buffer.go
pageBuffer
protocol/buffer.go
pageRef
protocol/buffer.go
Calls
no outgoing calls
Tested by
15
TestMemberMetadata
Function · 0.52
TestJoinGroupResponse
Function · 0.52
TestProtocol
Function · 0.52
TestSASLAuthenticateRequestV0
Function · 0.52
TestSASLAuthenticateResponseV0
Function · 0.52
TestOffsetFetchResponseV1
Function · 0.52
TestMessageSetReader
Function · 0.52
TestCreateTopicsResponse
Function · 0.52
TestDeleteTopicsResponseV1
Function · 0.52
TestOffsetCommitResponseV2
Function · 0.52
TestReadStringArray
Function · 0.52
TestReadMapStringInt32
Function · 0.52