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
48 lines
984 B
Go
48 lines
984 B
Go
package sarama
|
|
|
|
// DescribeAclsRequest is a describe acl request type
|
|
type DescribeAclsRequest struct {
|
|
Version int
|
|
AclFilter
|
|
}
|
|
|
|
func (d *DescribeAclsRequest) setVersion(v int16) {
|
|
d.Version = int(v)
|
|
}
|
|
|
|
func (d *DescribeAclsRequest) encode(pe packetEncoder) error {
|
|
d.AclFilter.Version = d.Version
|
|
return d.AclFilter.encode(pe)
|
|
}
|
|
|
|
func (d *DescribeAclsRequest) decode(pd packetDecoder, version int16) (err error) {
|
|
d.Version = int(version)
|
|
d.AclFilter.Version = int(version)
|
|
return d.AclFilter.decode(pd, version)
|
|
}
|
|
|
|
func (d *DescribeAclsRequest) key() int16 {
|
|
return apiKeyDescribeAcls
|
|
}
|
|
|
|
func (d *DescribeAclsRequest) version() int16 {
|
|
return int16(d.Version)
|
|
}
|
|
|
|
func (d *DescribeAclsRequest) headerVersion() int16 {
|
|
return 1
|
|
}
|
|
|
|
func (d *DescribeAclsRequest) isValidVersion() bool {
|
|
return d.Version >= 0 && d.Version <= 1
|
|
}
|
|
|
|
func (d *DescribeAclsRequest) requiredVersion() KafkaVersion {
|
|
switch d.Version {
|
|
case 1:
|
|
return V2_0_0_0
|
|
default:
|
|
return V0_11_0_0
|
|
}
|
|
}
|