mirror of
https://github.com/hanzoai/traces.git
synced 2026-10-30 18:20:41 +00:00
MarioandGitHub
e0354d1bed
* Update Prometheus to v0.307.2 * Update otel collector * Update OTel collector
55 lines
1.0 KiB
Go
55 lines
1.0 KiB
Go
package sarama
|
|
|
|
type SaslHandshakeResponse struct {
|
|
Version int16
|
|
Err KError
|
|
EnabledMechanisms []string
|
|
}
|
|
|
|
func (r *SaslHandshakeResponse) setVersion(v int16) {
|
|
r.Version = v
|
|
}
|
|
|
|
func (r *SaslHandshakeResponse) encode(pe packetEncoder) error {
|
|
pe.putKError(r.Err)
|
|
return pe.putStringArray(r.EnabledMechanisms)
|
|
}
|
|
|
|
func (r *SaslHandshakeResponse) decode(pd packetDecoder, version int16) (err error) {
|
|
r.Err, err = pd.getKError()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if r.EnabledMechanisms, err = pd.getStringArray(); err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (r *SaslHandshakeResponse) key() int16 {
|
|
return apiKeySaslHandshake
|
|
}
|
|
|
|
func (r *SaslHandshakeResponse) version() int16 {
|
|
return r.Version
|
|
}
|
|
|
|
func (r *SaslHandshakeResponse) headerVersion() int16 {
|
|
return 0
|
|
}
|
|
|
|
func (r *SaslHandshakeResponse) isValidVersion() bool {
|
|
return r.Version >= 0 && r.Version <= 1
|
|
}
|
|
|
|
func (r *SaslHandshakeResponse) requiredVersion() KafkaVersion {
|
|
switch r.Version {
|
|
case 1:
|
|
return V1_0_0_0
|
|
default:
|
|
return V0_10_0_0
|
|
}
|
|
}
|