rename fn

travisjeffery · Jan 24, 2017 · b1fe2ec · b1fe2ec
1 parent 42ca154
commit b1fe2ec
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git 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
@@ -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