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
52 lines
934 B
Go
52 lines
934 B
Go
package sarama
|
|
|
|
type SaslHandshakeRequest struct {
|
|
Mechanism string
|
|
Version int16
|
|
}
|
|
|
|
func (r *SaslHandshakeRequest) setVersion(v int16) {
|
|
r.Version = v
|
|
}
|
|
|
|
func (r *SaslHandshakeRequest) encode(pe packetEncoder) error {
|
|
if err := pe.putString(r.Mechanism); err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (r *SaslHandshakeRequest) decode(pd packetDecoder, version int16) (err error) {
|
|
if r.Mechanism, err = pd.getString(); err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (r *SaslHandshakeRequest) key() int16 {
|
|
return apiKeySaslHandshake
|
|
}
|
|
|
|
func (r *SaslHandshakeRequest) version() int16 {
|
|
return r.Version
|
|
}
|
|
|
|
func (r *SaslHandshakeRequest) headerVersion() int16 {
|
|
return 1
|
|
}
|
|
|
|
func (r *SaslHandshakeRequest) isValidVersion() bool {
|
|
return r.Version >= 0 && r.Version <= 1
|
|
}
|
|
|
|
func (r *SaslHandshakeRequest) requiredVersion() KafkaVersion {
|
|
switch r.Version {
|
|
case 1:
|
|
return V1_0_0_0
|
|
default:
|
|
return V0_10_0_0
|
|
}
|
|
}
|