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

Method encode

api_versions_response.go:153–174  ·  view source on GitHub ↗
(pe packetEncoder)

Source from the content-addressed store, hash-verified

151}
152
153func (r *ApiVersionsResponse) encode(pe packetEncoder) (err error) {
154 pe.putInt16(r.ErrorCode)
155
156 if err := pe.putArrayLength(len(r.ApiKeys)); err != nil {
157 return err
158 }
159 for _, block := range r.ApiKeys {
160 if err := block.encode(pe, r.Version); err != nil {
161 return err
162 }
163 }
164
165 if r.Version >= 1 {
166 pe.putInt32(r.ThrottleTimeMs)
167 }
168
169 if r.Version >= 3 {
170 return r.encodeTaggedFields(pe)
171 }
172
173 return nil
174}
175
176func (r *ApiVersionsResponse) encodeTaggedFields(pe packetEncoder) error {
177 type taggedField struct {

Callers

nothing calls this directly

Calls 5

encodeTaggedFieldsMethod · 0.95
putInt16Method · 0.65
putArrayLengthMethod · 0.65
encodeMethod · 0.65
putInt32Method · 0.65

Tested by

no test coverage detected