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