MCPcopy
hub / github.com/IBM/sarama / encode

Method encode

describe_groups_response.go:139–172  ·  view source on GitHub ↗
(pe packetEncoder, version int16)

Source from the content-addressed store, hash-verified

137}
138
139func (gd *GroupDescription) encode(pe packetEncoder, version int16) (err error) {
140 gd.Version = version
141 pe.putInt16(gd.ErrorCode)
142
143 if err := pe.putString(gd.GroupId); err != nil {
144 return err
145 }
146 if err := pe.putString(gd.State); err != nil {
147 return err
148 }
149 if err := pe.putString(gd.ProtocolType); err != nil {
150 return err
151 }
152 if err := pe.putString(gd.Protocol); err != nil {
153 return err
154 }
155
156 if err := pe.putArrayLength(len(gd.Members)); err != nil {
157 return err
158 }
159
160 for _, block := range gd.Members {
161 if err := block.encode(pe, gd.Version); err != nil {
162 return err
163 }
164 }
165
166 if gd.Version >= 3 {
167 pe.putInt32(gd.AuthorizedOperations)
168 }
169
170 pe.putEmptyTaggedFieldArray()
171 return nil
172}
173
174func (gd *GroupDescription) decode(pd packetDecoder, version int16) (err error) {
175 gd.Version = version

Callers

nothing calls this directly

Calls 6

putInt16Method · 0.65
putStringMethod · 0.65
putArrayLengthMethod · 0.65
encodeMethod · 0.65
putInt32Method · 0.65

Tested by

no test coverage detected