Little naming changes for consistency

broker.go

@@ -164,7 +164,7 @@ func (b *broker) rcvResponseLoop() {
 	}
 }
 
-func (b *broker) sendAndReceive(clientID *string, req requestEncoder, res decoder) error {
+func (b *broker) SendAndReceive(clientID *string, req requestEncoder, res decoder) error {
 	fullRequest := request{b.correlation_id, clientID, req}
 	packet, err := buildBytes(&fullRequest)
 	if err != nil {

broker_manager.go

@@ -110,7 +110,7 @@ func (bm *brokerManager) sendToPartition(topic string, partition int32, req requ
 		return err
 	}
 
-	err = b.sendAndReceive(bm.client.id, req, res)
+	err = b.SendAndReceive(bm.client.id, req, res)
 	switch err.(type) {
 	case EncodingError:
 		// encoding errors are our problem, not the broker's, so just return them
@@ -141,7 +141,7 @@ func (bm *brokerManager) getDefault() *broker {
 
 func (bm *brokerManager) sendToAny(req requestEncoder, res decoder) error {
 	for b := bm.getDefault(); b != nil; b = bm.getDefault() {
-		err := b.sendAndReceive(bm.client.id, req, res)
+		err := b.SendAndReceive(bm.client.id, req, res)
 		switch err.(type) {
 		case nil, EncodingError:
 			return err
@@ -155,7 +155,7 @@ func (bm *brokerManager) sendToAny(req requestEncoder, res decoder) error {
 }
 
 func (bm *brokerManager) refreshTopics(topics []*string) error {
-	response := new(metadata)
+	response := new(metadataResponse)
 	err := bm.sendToAny(&metadataRequest{topics}, response)
 	if err != nil {
 		return err

metadata_response.go

@@ -1,11 +1,11 @@
 package kafka
 
-type metadata struct {
+type metadataResponse struct {
 	brokers []broker
 	topics  []topicMetadata
 }
 
-func (m *metadata) encode(pe packetEncoder) {
+func (m *metadataResponse) encode(pe packetEncoder) {
 	pe.putInt32(int32(len(m.brokers)))
 	for i := range m.brokers {
 		(&m.brokers[i]).encode(pe)
@@ -16,7 +16,7 @@ func (m *metadata) encode(pe packetEncoder) {
 	}
 }
 
-func (m *metadata) decode(pd packetDecoder) (err error) {
+func (m *metadataResponse) decode(pd packetDecoder) (err error) {
 	n, err := pd.getArrayCount()
 	if err != nil {
 		return err