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

Method writeTo

listgroups.go:116–120  ·  view source on GitHub ↗
(wb *writeBuffer)

Source from the content-addressed store, hash-verified

114}
115
116func (t listGroupsResponseV1) writeTo(wb *writeBuffer) {
117 wb.writeInt32(t.ThrottleTimeMS)
118 wb.writeInt16(t.ErrorCode)
119 wb.writeArray(len(t.Groups), func(i int) { t.Groups[i].writeTo(wb) })
120}
121
122func (t *listGroupsResponseV1) readFrom(r *bufio.Reader, size int) (remain int, err error) {
123 if remain, err = readInt32(r, size, &t.ThrottleTimeMS); err != nil {

Callers 1

TestListGroupsResponseV1Function · 0.95

Calls 4

writeArrayMethod · 0.80
writeToMethod · 0.65
writeInt32Method · 0.45
writeInt16Method · 0.45

Tested by 1

TestListGroupsResponseV1Function · 0.76