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

Method readFrom

joingroup.go:301–309  ·  view source on GitHub ↗
(r *bufio.Reader, size int)

Source from the content-addressed store, hash-verified

299}
300
301func (t *joinGroupResponseMember) readFrom(r *bufio.Reader, size int) (remain int, err error) {
302 if remain, err = readString(r, size, &t.MemberID); err != nil {
303 return
304 }
305 if remain, err = readBytes(r, remain, &t.MemberMetadata); err != nil {
306 return
307 }
308 return
309}
310
311type joinGroupResponse struct {
312 v apiVersion // v1, v2

Callers

nothing calls this directly

Calls 2

readStringFunction · 0.85
readBytesFunction · 0.85

Tested by

no test coverage detected