blob: 5222d46ee5bb6b465c6a85ae09a05f0f7a3f2f36 [file] [log] [blame]
khenaidooac637102019-01-14 15:44:34 -05001package sarama
2
Scott Baker8461e152019-10-01 14:44:30 -07003//DescribeAclsRequest is a secribe acl request type
khenaidooac637102019-01-14 15:44:34 -05004type DescribeAclsRequest struct {
William Kurkiandaa6bb22019-03-07 12:26:28 -05005 Version int
khenaidooac637102019-01-14 15:44:34 -05006 AclFilter
7}
8
9func (d *DescribeAclsRequest) encode(pe packetEncoder) error {
William Kurkiandaa6bb22019-03-07 12:26:28 -050010 d.AclFilter.Version = d.Version
khenaidooac637102019-01-14 15:44:34 -050011 return d.AclFilter.encode(pe)
12}
13
14func (d *DescribeAclsRequest) decode(pd packetDecoder, version int16) (err error) {
William Kurkiandaa6bb22019-03-07 12:26:28 -050015 d.Version = int(version)
16 d.AclFilter.Version = int(version)
khenaidooac637102019-01-14 15:44:34 -050017 return d.AclFilter.decode(pd, version)
18}
19
20func (d *DescribeAclsRequest) key() int16 {
21 return 29
22}
23
24func (d *DescribeAclsRequest) version() int16 {
William Kurkiandaa6bb22019-03-07 12:26:28 -050025 return int16(d.Version)
khenaidooac637102019-01-14 15:44:34 -050026}
27
28func (d *DescribeAclsRequest) requiredVersion() KafkaVersion {
William Kurkiandaa6bb22019-03-07 12:26:28 -050029 switch d.Version {
30 case 1:
31 return V2_0_0_0
32 default:
33 return V0_11_0_0
34 }
khenaidooac637102019-01-14 15:44:34 -050035}