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

Interface Bytes

protocol/buffer.go:24–28  ·  protocol/buffer.go::Bytes

Bytes is an interface implemented by types that represent immutable sequences of bytes. Bytes values are used to abstract the location where record keys and values are read from (e.g. in-memory buffers, network sockets, files). The Close method should be called to release resources held by the obj

Source from the content-addressed store, hash-verified

22// Bytes values are generally not safe to use concurrently from multiple
23// goroutines.
24type Bytes interface {
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.
31//

Callers 8

TestMemberMetadataFunction · 0.65
TestJoinGroupResponseFunction · 0.65
TestProtocolFunction · 0.65
TestMessageSetReaderFunction · 0.65
readMessageV1Method · 0.65

Implementers 4

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

Calls

no outgoing calls

Tested by

no test coverage detected