diff options
Diffstat (limited to 'weed/mq/pub_balancer/balance_action.go')
| -rw-r--r-- | weed/mq/pub_balancer/balance_action.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/mq/pub_balancer/balance_action.go b/weed/mq/pub_balancer/balance_action.go index c29ec3469..a2d888b2a 100644 --- a/weed/mq/pub_balancer/balance_action.go +++ b/weed/mq/pub_balancer/balance_action.go @@ -8,10 +8,10 @@ import ( "google.golang.org/grpc" ) -// Balancer <= PublisherToPubBalancer() <= Broker <=> Publish() -// ExecuteBalanceActionMove from Balancer => AssignTopicPartitions() => Broker => Publish() +// PubBalancer <= PublisherToPubBalancer() <= Broker <=> Publish() +// ExecuteBalanceActionMove from PubBalancer => AssignTopicPartitions() => Broker => Publish() -func (balancer *Balancer) ExecuteBalanceActionMove(move *BalanceActionMove, grpcDialOption grpc.DialOption) error { +func (balancer *PubBalancer) ExecuteBalanceActionMove(move *BalanceActionMove, grpcDialOption grpc.DialOption) error { if _, found := balancer.Brokers.Get(move.SourceBroker); !found { return fmt.Errorf("source broker %s not found", move.SourceBroker) } |