1package sarama
2
3type SaslAuthenticateResponse struct {
4	Err           KError
5	ErrorMessage  *string
6	SaslAuthBytes []byte
7}
8
9func (r *SaslAuthenticateResponse) encode(pe packetEncoder) error {
10	pe.putInt16(int16(r.Err))
11	if err := pe.putNullableString(r.ErrorMessage); err != nil {
12		return err
13	}
14	return pe.putBytes(r.SaslAuthBytes)
15}
16
17func (r *SaslAuthenticateResponse) decode(pd packetDecoder, version int16) error {
18	kerr, err := pd.getInt16()
19	if err != nil {
20		return err
21	}
22
23	r.Err = KError(kerr)
24
25	if r.ErrorMessage, err = pd.getNullableString(); err != nil {
26		return err
27	}
28
29	r.SaslAuthBytes, err = pd.getBytes()
30
31	return err
32}
33
34func (r *SaslAuthenticateResponse) key() int16 {
35	return APIKeySASLAuth
36}
37
38func (r *SaslAuthenticateResponse) version() int16 {
39	return 0
40}
41
42func (r *SaslAuthenticateResponse) headerVersion() int16 {
43	return 0
44}
45
46func (r *SaslAuthenticateResponse) requiredVersion() KafkaVersion {
47	return V1_0_0_0
48}
49