Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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
118
type
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
TestReadNewBytes
Function · 0.65
peekResponseSizeAndID
Method · 0.65
peekRead
Function · 0.65
readVarInt
Function · 0.65
ReadFrom
Method · 0.65
Peek
Method · 0.65
Implementers
1
Conn
protocol/conn.go
Calls
no outgoing calls
Tested by
1
TestReadNewBytes
Function · 0.52