blob: 69dfc3178ec29b0fcdf99e8dd7834149ed58683c [file] [log] [blame]
khenaidooac637102019-01-14 15:44:34 -05001package sarama
2
3type SaslHandshakeResponse struct {
4 Err KError
5 EnabledMechanisms []string
6}
7
8func (r *SaslHandshakeResponse) encode(pe packetEncoder) error {
9 pe.putInt16(int16(r.Err))
10 return pe.putStringArray(r.EnabledMechanisms)
11}
12
13func (r *SaslHandshakeResponse) decode(pd packetDecoder, version int16) error {
14 kerr, err := pd.getInt16()
15 if err != nil {
16 return err
17 }
18
19 r.Err = KError(kerr)
20
21 if r.EnabledMechanisms, err = pd.getStringArray(); err != nil {
22 return err
23 }
24
25 return nil
26}
27
28func (r *SaslHandshakeResponse) key() int16 {
29 return 17
30}
31
32func (r *SaslHandshakeResponse) version() int16 {
33 return 0
34}
35
khenaidood948f772021-08-11 17:49:24 -040036func (r *SaslHandshakeResponse) headerVersion() int16 {
37 return 0
38}
39
khenaidooac637102019-01-14 15:44:34 -050040func (r *SaslHandshakeResponse) requiredVersion() KafkaVersion {
41 return V0_10_0_0
42}