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

Method encode

alter_configs_request.go:65–85  ·  view source on GitHub ↗
(pe packetEncoder)

Source from the content-addressed store, hash-verified

63}
64
65func (a *AlterConfigsResource) encode(pe packetEncoder) error {
66 pe.putInt8(int8(a.Type))
67
68 if err := pe.putString(a.Name); err != nil {
69 return err
70 }
71
72 if err := pe.putArrayLength(len(a.ConfigEntries)); err != nil {
73 return err
74 }
75 for configKey, configValue := range a.ConfigEntries {
76 if err := pe.putString(configKey); err != nil {
77 return err
78 }
79 if err := pe.putNullableString(configValue); err != nil {
80 return err
81 }
82 }
83
84 return nil
85}
86
87func (a *AlterConfigsResource) decode(pd packetDecoder, version int16) error {
88 t, err := pd.getInt8()

Callers

nothing calls this directly

Calls 4

putInt8Method · 0.65
putStringMethod · 0.65
putArrayLengthMethod · 0.65
putNullableStringMethod · 0.65

Tested by

no test coverage detected