cubefs

1
package sarama
2

3
type SaslAuthenticateRequest struct {
4
	// Version defines the protocol version to use for encode and decode
5
	Version       int16
6
	SaslAuthBytes []byte
7
}
8

9
// APIKeySASLAuth is the API key for the SaslAuthenticate Kafka API
10
const APIKeySASLAuth = 36
11

12
func (r *SaslAuthenticateRequest) encode(pe packetEncoder) error {
13
	return pe.putBytes(r.SaslAuthBytes)
14
}
15

16
func (r *SaslAuthenticateRequest) decode(pd packetDecoder, version int16) (err error) {
17
	r.Version = version
18
	r.SaslAuthBytes, err = pd.getBytes()
19
	return err
20
}
21

22
func (r *SaslAuthenticateRequest) key() int16 {
23
	return APIKeySASLAuth
24
}
25

26
func (r *SaslAuthenticateRequest) version() int16 {
27
	return r.Version
28
}
29

30
func (r *SaslAuthenticateRequest) headerVersion() int16 {
31
	return 1
32
}
33

34
func (r *SaslAuthenticateRequest) requiredVersion() KafkaVersion {
35
	switch r.Version {
36
	case 1:
37
		return V2_2_0_0
38
	default:
39
		return V1_0_0_0
40
	}
41
}
42