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

Method read

protocol/decode.go:151–157  ·  view source on GitHub ↗
(n int)

Source from the content-addressed store, hash-verified

149}
150
151func (d *decoder) read(n int) []byte {
152 b := make([]byte, n)
153 n, err := io.ReadFull(d, b)
154 b = b[:n]
155 d.setError(err)
156 return b
157}
158
159func (d *decoder) writeTo(w io.Writer, n int) {
160 limit := d.remain

Callers 9

ReadRequestFunction · 0.95
readStringMethod · 0.95
readVarStringMethod · 0.95
readCompactStringMethod · 0.95
readBytesMethod · 0.95
readVarBytesMethod · 0.95
readCompactBytesMethod · 0.95
ReadResponseFunction · 0.95
structDecodeFuncOfFunction · 0.45

Calls 1

setErrorMethod · 0.95

Tested by

no test coverage detected