Add test for DescribeLogDirsRequest

describe_log_dirs_request_test.go

@@ -0,0 +1,31 @@
+package sarama
+
+import "testing"
+
+var (
+	emptyDescribeLogDirsRequest = []byte{255, 255, 255, 255} // Empty array (array length -1 sent)
+	topicDescribeLogDirsRequest = []byte{
+		0, 0, 0, 1, // DescribeTopics array, Array length 1
+		0, 6, // Topic name length 18
+		'r', 'a', 'n', 'd', 'o', 'm', // Topic name
+		0, 0, 0, 2, // PartitionIDs int32 array, Array length 2
+		0, 0, 0, 25, // PartitionID 25
+		0, 0, 0, 26, // PartitionID 26
+	}
+)
+
+func TestDescribeLogDirsRequest(t *testing.T) {
+	request := &DescribeLogDirsRequest{
+		Version:        0,
+		DescribeTopics: []DescribeLogDirsRequestTopic{},
+	}
+	testRequest(t, "no topics", request, emptyDescribeLogDirsRequest)
+
+	request.DescribeTopics = []DescribeLogDirsRequestTopic{
+		DescribeLogDirsRequestTopic{
+			Topic:        "random",
+			PartitionIDs: []int32{25, 26},
+		},
+	}
+	testRequest(t, "no topics", request, topicDescribeLogDirsRequest)
+}

request.go

@@ -158,6 +158,8 @@ func allocateBody(key, version int16) protocolBody {
 		return &DescribeConfigsRequest{}
 	case 33:
 		return &AlterConfigsRequest{}
+	case 35:
+		return &DescribeLogDirsRequest{}
 	case 36:
 		return &SaslAuthenticateRequest{}
 	case 37: