cubefs

1
package sarama
2

3
// DescribeAclsRequest is a secribe acl request type
4
type DescribeAclsRequest struct {
5
	Version int
6
	AclFilter
7
}
8

9
func (d *DescribeAclsRequest) encode(pe packetEncoder) error {
10
	d.AclFilter.Version = d.Version
11
	return d.AclFilter.encode(pe)
12
}
13

14
func (d *DescribeAclsRequest) decode(pd packetDecoder, version int16) (err error) {
15
	d.Version = int(version)
16
	d.AclFilter.Version = int(version)
17
	return d.AclFilter.decode(pd, version)
18
}
19

20
func (d *DescribeAclsRequest) key() int16 {
21
	return 29
22
}
23

24
func (d *DescribeAclsRequest) version() int16 {
25
	return int16(d.Version)
26
}
27

28
func (d *DescribeAclsRequest) headerVersion() int16 {
29
	return 1
30
}
31

32
func (d *DescribeAclsRequest) requiredVersion() KafkaVersion {
33
	switch d.Version {
34
	case 1:
35
		return V2_0_0_0
36
	default:
37
		return V0_11_0_0
38
	}
39
}
40