From 2fbceca959c5b95a99635aeee162e976ed31745e Mon Sep 17 00:00:00 2001 From: chrislu Date: Mon, 1 Sep 2025 15:40:09 -0700 Subject: [PATCH] fmt --- weed/mq/broker/broker_server.go | 5 +++-- weed/mq/sub_coordinator/sub_coordinator.go | 1 + weed/mq/topic/local_manager.go | 3 ++- 3 files changed, 6 insertions(+), 3 deletions(-) diff --git a/weed/mq/broker/broker_server.go b/weed/mq/broker/broker_server.go index d80fa91a4..714348798 100644 --- a/weed/mq/broker/broker_server.go +++ b/weed/mq/broker/broker_server.go @@ -2,13 +2,14 @@ package broker import ( "context" + "sync" + "time" + "github.com/seaweedfs/seaweedfs/weed/filer_client" "github.com/seaweedfs/seaweedfs/weed/glog" "github.com/seaweedfs/seaweedfs/weed/mq/pub_balancer" "github.com/seaweedfs/seaweedfs/weed/mq/sub_coordinator" "github.com/seaweedfs/seaweedfs/weed/mq/topic" - "sync" - "time" "github.com/seaweedfs/seaweedfs/weed/cluster" "github.com/seaweedfs/seaweedfs/weed/pb/mq_pb" diff --git a/weed/mq/sub_coordinator/sub_coordinator.go b/weed/mq/sub_coordinator/sub_coordinator.go index a26fb9dc5..df86da95f 100644 --- a/weed/mq/sub_coordinator/sub_coordinator.go +++ b/weed/mq/sub_coordinator/sub_coordinator.go @@ -2,6 +2,7 @@ package sub_coordinator import ( "fmt" + cmap "github.com/orcaman/concurrent-map/v2" "github.com/seaweedfs/seaweedfs/weed/filer_client" "github.com/seaweedfs/seaweedfs/weed/pb/mq_pb" diff --git a/weed/mq/topic/local_manager.go b/weed/mq/topic/local_manager.go index 82ee18c4a..328684e4b 100644 --- a/weed/mq/topic/local_manager.go +++ b/weed/mq/topic/local_manager.go @@ -1,11 +1,12 @@ package topic import ( + "time" + cmap "github.com/orcaman/concurrent-map/v2" "github.com/seaweedfs/seaweedfs/weed/pb/mq_pb" "github.com/seaweedfs/seaweedfs/weed/pb/schema_pb" "github.com/shirou/gopsutil/v3/cpu" - "time" ) // LocalTopicManager manages topics on local broker