cubefs

1
package sarama
2

3
type SaslAuthenticateResponse struct {
4
	// Version defines the protocol version to use for encode and decode
5
	Version           int16
6
	Err               KError
7
	ErrorMessage      *string
8
	SaslAuthBytes     []byte
9
	SessionLifetimeMs int64
10
}
11

12
func (r *SaslAuthenticateResponse) encode(pe packetEncoder) error {
13
	pe.putInt16(int16(r.Err))
14
	if err := pe.putNullableString(r.ErrorMessage); err != nil {
15
		return err
16
	}
17
	if err := pe.putBytes(r.SaslAuthBytes); err != nil {
18
		return err
19
	}
20
	if r.Version > 0 {
21
		pe.putInt64(r.SessionLifetimeMs)
22
	}
23
	return nil
24
}
25

26
func (r *SaslAuthenticateResponse) decode(pd packetDecoder, version int16) error {
27
	r.Version = version
28
	kerr, err := pd.getInt16()
29
	if err != nil {
30
		return err
31
	}
32

33
	r.Err = KError(kerr)
34

35
	if r.ErrorMessage, err = pd.getNullableString(); err != nil {
36
		return err
37
	}
38

39
	if r.SaslAuthBytes, err = pd.getBytes(); err != nil {
40
		return err
41
	}
42

43
	if version > 0 {
44
		r.SessionLifetimeMs, err = pd.getInt64()
45
	}
46

47
	return err
48
}
49

50
func (r *SaslAuthenticateResponse) key() int16 {
51
	return APIKeySASLAuth
52
}
53

54
func (r *SaslAuthenticateResponse) version() int16 {
55
	return r.Version
56
}
57

58
func (r *SaslAuthenticateResponse) headerVersion() int16 {
59
	return 0
60
}
61

62
func (r *SaslAuthenticateResponse) requiredVersion() KafkaVersion {
63
	switch r.Version {
64
	case 1:
65
		return V2_2_0_0
66
	default:
67
		return V1_0_0_0
68
	}
69
}
70