From 23f334dd13f1bf801a6f5df14742db8526b29afe Mon Sep 17 00:00:00 2001 From: chrislu Date: Sun, 24 Sep 2023 23:36:43 -0700 Subject: [PATCH] comment --- weed/mq/broker/broker_grpc_balancer.go | 2 +- weed/mq/topic/local_manager.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/weed/mq/broker/broker_grpc_balancer.go b/weed/mq/broker/broker_grpc_balancer.go index 079a1612f..5e23f89df 100644 --- a/weed/mq/broker/broker_grpc_balancer.go +++ b/weed/mq/broker/broker_grpc_balancer.go @@ -8,7 +8,7 @@ import ( "google.golang.org/grpc/status" ) -// BrokerConnectToBalancer receives connections from brokers and collects stats +// ConnectToBalancer receives connections from brokers and collects stats func (broker *MessageQueueBroker) ConnectToBalancer(stream mq_pb.SeaweedMessaging_ConnectToBalancerServer) error { if !broker.lockAsBalancer.IsLocked() { return status.Errorf(codes.Unavailable, "not current broker balancer") diff --git a/weed/mq/topic/local_manager.go b/weed/mq/topic/local_manager.go index a2bc23f24..e3ee46a1e 100644 --- a/weed/mq/topic/local_manager.go +++ b/weed/mq/topic/local_manager.go @@ -19,7 +19,7 @@ func NewLocalTopicManager() *LocalTopicManager { } } -// AddTopic adds a topic to the local topic manager +// AddTopicPartition adds a topic to the local topic manager func (manager *LocalTopicManager) AddTopicPartition(topic Topic, localPartition *LocalPartition) { localTopic, ok := manager.topics.Get(topic.String()) if !ok {