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

Method writeTo

syncgroup.go:275–278  ·  view source on GitHub ↗
(wb *writeBuffer)

Source from the content-addressed store, hash-verified

273}
274
275func (t syncGroupResponseV0) writeTo(wb *writeBuffer) {
276 wb.writeInt16(t.ErrorCode)
277 wb.writeBytes(t.MemberAssignments)
278}
279
280func (t *syncGroupResponseV0) readFrom(r *bufio.Reader, sz int) (remain int, err error) {
281 if remain, err = readInt16(r, sz, &t.ErrorCode); err != nil {

Callers 2

TestSyncGroupResponseV0Function · 0.95

Calls 2

writeInt16Method · 0.45
writeBytesMethod · 0.45

Tested by 2

TestSyncGroupResponseV0Function · 0.76