aboutsummaryrefslogtreecommitdiff
path: root/weed/mq/balancer/allocate.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/mq/balancer/allocate.go')
-rw-r--r--weed/mq/balancer/allocate.go20
1 files changed, 0 insertions, 20 deletions
diff --git a/weed/mq/balancer/allocate.go b/weed/mq/balancer/allocate.go
deleted file mode 100644
index d594c60fb..000000000
--- a/weed/mq/balancer/allocate.go
+++ /dev/null
@@ -1,20 +0,0 @@
-package balancer
-
-import (
- cmap "github.com/orcaman/concurrent-map/v2"
- "github.com/seaweedfs/seaweedfs/weed/pb/mq_pb"
-)
-
-func allocateTopicPartitions(brokers cmap.ConcurrentMap[string, *BrokerStats], partitionCount int) (assignments []*mq_pb.BrokerPartitionAssignment) {
- return []*mq_pb.BrokerPartitionAssignment{
- {
- LeaderBroker: "localhost:17777",
- FollowerBrokers: []string{"localhost:17777"},
- Partition: &mq_pb.Partition{
- RingSize: MaxPartitionCount,
- RangeStart: 0,
- RangeStop: MaxPartitionCount,
- },
- },
- }
-}