weed/mq/balancer/balancer.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

package balancer

import cmap "github.com/orcaman/concurrent-map"

type Balancer struct {
	brokers cmap.ConcurrentMap[string, *BrokerStats]
}
type BrokerStats struct {
	stats map[TopicPartition]*TopicPartitionStats
}

type TopicPartition struct {
	Topic      string
	RangeStart int32
	RangeStop  int32
}

type TopicPartitionStats struct {
	Throughput int64
}