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
47 lines
980 B
Go
47 lines
980 B
Go
package sarama
|
|
|
|
type SaslAuthenticateRequest struct {
|
|
// Version defines the protocol version to use for encode and decode
|
|
Version int16
|
|
SaslAuthBytes []byte
|
|
}
|
|
|
|
func (r *SaslAuthenticateRequest) setVersion(v int16) {
|
|
r.Version = v
|
|
}
|
|
|
|
func (r *SaslAuthenticateRequest) encode(pe packetEncoder) error {
|
|
return pe.putBytes(r.SaslAuthBytes)
|
|
}
|
|
|
|
func (r *SaslAuthenticateRequest) decode(pd packetDecoder, version int16) (err error) {
|
|
r.Version = version
|
|
r.SaslAuthBytes, err = pd.getBytes()
|
|
return err
|
|
}
|
|
|
|
func (r *SaslAuthenticateRequest) key() int16 {
|
|
return apiKeySASLAuth
|
|
}
|
|
|
|
func (r *SaslAuthenticateRequest) version() int16 {
|
|
return r.Version
|
|
}
|
|
|
|
func (r *SaslAuthenticateRequest) headerVersion() int16 {
|
|
return 1
|
|
}
|
|
|
|
func (r *SaslAuthenticateRequest) isValidVersion() bool {
|
|
return r.Version >= 0 && r.Version <= 1
|
|
}
|
|
|
|
func (r *SaslAuthenticateRequest) requiredVersion() KafkaVersion {
|
|
switch r.Version {
|
|
case 1:
|
|
return V2_2_0_0
|
|
default:
|
|
return V1_0_0_0
|
|
}
|
|
}
|