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

Method Peek

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

Source from the content-addressed store, hash-verified

118type bufferedReader interface {
119 Discard(int) (int, error)
120 Peek(int) ([]byte, error)
121}
122
123// bytesBuffer is an interface implemented by types like bytes.Buffer, which we

Callers 6

TestReadNewBytesFunction · 0.65
peekResponseSizeAndIDMethod · 0.65
peekReadFunction · 0.65
readVarIntFunction · 0.65
ReadFromMethod · 0.65
PeekMethod · 0.65

Implementers 1

Connprotocol/conn.go

Calls

no outgoing calls

Tested by 1

TestReadNewBytesFunction · 0.52