From b1fe2ec4b5f14389ea2842220b9deb8ba2bcffcc Mon Sep 17 00:00:00 2001
From: Travis Jeffery <tj@travisjeffery.com>
Date: Tue, 24 Jan 2017 01:22:33 -0500
Subject: [PATCH] rename fn

---
 broker/broker.go | 6 +++---
 broker/raft.go   | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/broker/broker.go b/broker/broker.go
index 37e12c80..838c9430 100644
--- a/broker/broker.go
+++ b/broker/broker.go
@@ -159,11 +159,11 @@ func (s *Broker) Partition(topic string, partition int32) (*jocko.Partition, err
 }
 
 func (s *Broker) AddPartition(partition *jocko.Partition) error {
-	return s.apply(addPartition, partition)
+	return s.raftApply(addPartition, partition)
 }
 
 func (s *Broker) AddBroker(broker jocko.BrokerConn) error {
-	return s.apply(addBroker, broker)
+	return s.raftApply(addBroker, broker)
 }
 
 func (s *Broker) BrokerConn(id int32) *jocko.BrokerConn {
@@ -278,7 +278,7 @@ func (s *Broker) DeleteTopics(topics ...string) error {
 }
 
 func (s *Broker) DeleteTopic(topic string) error {
-	return s.apply(deleteTopic, &jocko.Partition{Topic: topic})
+	return s.raftApply(deleteTopic, &jocko.Partition{Topic: topic})
 }
 
 func (s *Broker) deleteTopic(tp *jocko.Partition) error {
diff --git a/broker/raft.go b/broker/raft.go
index 9fce6390..bfb22687 100644
--- a/broker/raft.go
+++ b/broker/raft.go
@@ -95,7 +95,7 @@ func (b *Broker) setupRaft() (err error) {
 	return nil
 }
 
-func (s *Broker) apply(cmdType CmdType, data interface{}) error {
+func (s *Broker) raftApply(cmdType CmdType, data interface{}) error {
 	c, err := newCommand(cmdType, data)
 	if err != nil {
 		return err