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