blob: 90504df6f5222129d15de2e3ca28538452b190fb [file] [log] [blame]
Scott Bakered4efab2020-01-13 19:12:25 -08001package sarama
2
3type SaslAuthenticateRequest struct {
4 SaslAuthBytes []byte
5}
6
7// APIKeySASLAuth is the API key for the SaslAuthenticate Kafka API
8const APIKeySASLAuth = 36
9
10func (r *SaslAuthenticateRequest) encode(pe packetEncoder) error {
11 return pe.putBytes(r.SaslAuthBytes)
12}
13
14func (r *SaslAuthenticateRequest) decode(pd packetDecoder, version int16) (err error) {
15 r.SaslAuthBytes, err = pd.getBytes()
16 return err
17}
18
19func (r *SaslAuthenticateRequest) key() int16 {
20 return APIKeySASLAuth
21}
22
23func (r *SaslAuthenticateRequest) version() int16 {
24 return 0
25}
26
David K. Bainbridgebd6b2882021-08-26 13:31:02 +000027func (r *SaslAuthenticateRequest) headerVersion() int16 {
28 return 1
29}
30
Scott Bakered4efab2020-01-13 19:12:25 -080031func (r *SaslAuthenticateRequest) requiredVersion() KafkaVersion {
32 return V1_0_0_0
33}