acl_delete_response_test.go

package sarama

import (
	"testing"
	"time"
)

var deleteAclsResponse = []byte{
	0, 0, 0, 100,
	0, 0, 0, 1,
	0, 0, // no error
	255, 255, // no error message
	0, 0, 0, 1, // 1 matching acl
	0, 0, // no error
	255, 255, // no error message
	2, // resource type
	0, 5, 't', 'o', 'p', 'i', 'c',
	0, 9, 'p', 'r', 'i', 'n', 'c', 'i', 'p', 'a', 'l',
	0, 4, 'h', 'o', 's', 't',
	4,
	3,
}

func TestDeleteAclsResponse(t *testing.T) {
	resp := &DeleteAclsResponse{
		ThrottleTime: 100 * time.Millisecond,
		FilterResponses: []*FilterResponse{{
			MatchingAcls: []*MatchingAcl{{
				Resource: Resource{ResourceType: AclResourceTopic, ResourceName: "topic"},
				Acl:      Acl{Principal: "principal", Host: "host", Operation: AclOperationWrite, PermissionType: AclPermissionAllow},
			}},
		}},
	}

	testResponse(t, "", resp, deleteAclsResponse)
}