diff options
Diffstat (limited to 'weed/mq/pub_balancer/balancer.go')
| -rw-r--r-- | weed/mq/pub_balancer/balancer.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/mq/pub_balancer/balancer.go b/weed/mq/pub_balancer/balancer.go index 988b971af..5e8c8275e 100644 --- a/weed/mq/pub_balancer/balancer.go +++ b/weed/mq/pub_balancer/balancer.go @@ -32,9 +32,10 @@ type Balancer struct { // Collected from all brokers when they connect to the broker leader TopicToBrokers cmap.ConcurrentMap[string, *PartitionSlotToBrokerList] // key: topic name } + func NewBalancer() *Balancer { return &Balancer{ - Brokers: cmap.New[*BrokerStats](), + Brokers: cmap.New[*BrokerStats](), TopicToBrokers: cmap.New[*PartitionSlotToBrokerList](), } } |