CreateAcls sends a create acl request and returns a response or error
(request *CreateAclsRequest)
| 818 | |
| 819 | // CreateAcls sends a create acl request and returns a response or error |
| 820 | func (b *Broker) CreateAcls(request *CreateAclsRequest) (*CreateAclsResponse, error) { |
| 821 | response := new(CreateAclsResponse) |
| 822 | |
| 823 | err := b.sendAndReceive(request, response) |
| 824 | if err != nil { |
| 825 | return nil, err |
| 826 | } |
| 827 | |
| 828 | errs := make([]error, 0) |
| 829 | for _, res := range response.AclCreationResponses { |
| 830 | if !errors.Is(res.Err, ErrNoError) { |
| 831 | errs = append(errs, res.Err) |
| 832 | } |
| 833 | } |
| 834 | |
| 835 | if len(errs) > 0 { |
| 836 | return response, Wrap(ErrCreateACLs, errs...) |
| 837 | } |
| 838 | |
| 839 | return response, nil |
| 840 | } |
| 841 | |
| 842 | // DeleteAcls sends a delete acl request and returns a response or error |
| 843 | func (b *Broker) DeleteAcls(request *DeleteAclsRequest) (*DeleteAclsResponse, error) { |
no test coverage detected