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

Method readVarInt

message_reader.go:525–528  ·  view source on GitHub ↗
(val *int64)

Source from the content-addressed store, hash-verified

523}
524
525func (r *messageSetReader) readVarInt(val *int64) (err error) {
526 r.remain, err = readVarInt(r.reader, r.remain, val)
527 return
528}
529
530func (r *messageSetReader) readBytesWith(fn readBytesFunc) (err error) {
531 r.remain, err = readBytesWith(r.reader, r.remain, fn)

Callers 3

readMessageV2Method · 0.95
readMessageHeaderMethod · 0.95
runFuncMethod · 0.95

Calls 1

readVarIntFunction · 0.85

Tested by

no test coverage detected