diff options
| author | chrislu <chris.lu@gmail.com> | 2023-09-24 23:36:43 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2023-09-24 23:36:43 -0700 |
| commit | 23f334dd13f1bf801a6f5df14742db8526b29afe (patch) | |
| tree | 85b875b7585c332e1afe48fcc2ee650bb8f38703 | |
| parent | c7e05e4e716e43541bdf8b3486166d8566ae8582 (diff) | |
| download | seaweedfs-23f334dd13f1bf801a6f5df14742db8526b29afe.tar.xz seaweedfs-23f334dd13f1bf801a6f5df14742db8526b29afe.zip | |
comment
| -rw-r--r-- | weed/mq/broker/broker_grpc_balancer.go | 2 | ||||
| -rw-r--r-- | 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 { |