diff options
| author | chrislu <chris.lu@gmail.com> | 2024-01-11 23:03:35 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-01-11 23:03:35 -0800 |
| commit | 45994641e91a901d5ab826b393b09abcce3c0d81 (patch) | |
| tree | d0a423a3912c18ce8d2c56838d9874d946192f8f | |
| parent | 70a011a2249849ad44a82cf7f4592db7b9863b50 (diff) | |
| download | seaweedfs-45994641e91a901d5ab826b393b09abcce3c0d81.tar.xz seaweedfs-45994641e91a901d5ab826b393b09abcce3c0d81.zip | |
lint
| -rw-r--r-- | weed/mq/topic/local_manager.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/mq/topic/local_manager.go b/weed/mq/topic/local_manager.go index 173df090d..220dba0c8 100644 --- a/weed/mq/topic/local_manager.go +++ b/weed/mq/topic/local_manager.go @@ -34,7 +34,7 @@ func (manager *LocalTopicManager) AddTopicPartition(topic Topic, localPartition localTopic.Partitions = append(localTopic.Partitions, localPartition) } -// GetTopic gets a topic from the local topic manager +// GetTopicPartition gets a topic from the local topic manager func (manager *LocalTopicManager) GetTopicPartition(topic Topic, partition Partition) *LocalPartition { localTopic, ok := manager.topics.Get(topic.String()) if !ok { |