1package sarama
2
3type SaslHandshakeRequest struct {
4	Mechanism string
5	Version   int16
6}
7
8func (r *SaslHandshakeRequest) encode(pe packetEncoder) error {
9	if err := pe.putString(r.Mechanism); err != nil {
10		return err
11	}
12
13	return nil
14}
15
16func (r *SaslHandshakeRequest) decode(pd packetDecoder, version int16) (err error) {
17	if r.Mechanism, err = pd.getString(); err != nil {
18		return err
19	}
20
21	return nil
22}
23
24func (r *SaslHandshakeRequest) key() int16 {
25	return 17
26}
27
28func (r *SaslHandshakeRequest) version() int16 {
29	return r.Version
30}
31
32func (r *SaslHandshakeRequest) headerVersion() int16 {
33	return 1
34}
35
36func (r *SaslHandshakeRequest) requiredVersion() KafkaVersion {
37	return V0_10_0_0
38}
39