diff options
| author | chrislu <chris.lu@gmail.com> | 2023-09-24 21:19:51 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2023-09-24 22:00:43 -0700 |
| commit | 3cf9b8d62149ae0a163635ef480af2c01bae872b (patch) | |
| tree | 2e2be77ddd3e87130b713eadf7e067cfbbe3ff52 /weed/mq/balancer/balancer.go | |
| parent | b3f94feeded8f0beb411ade49bda09baa3c5443f (diff) | |
| download | seaweedfs-3cf9b8d62149ae0a163635ef480af2c01bae872b.tar.xz seaweedfs-3cf9b8d62149ae0a163635ef480af2c01bae872b.zip | |
create topic and report topicorigin/sub
Diffstat (limited to 'weed/mq/balancer/balancer.go')
| -rw-r--r-- | weed/mq/balancer/balancer.go | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/weed/mq/balancer/balancer.go b/weed/mq/balancer/balancer.go index b240f2d5f..4da735bd3 100644 --- a/weed/mq/balancer/balancer.go +++ b/weed/mq/balancer/balancer.go @@ -52,6 +52,11 @@ func (bs *BrokerStats) UpdateStats(stats *mq_pb.BrokerStats) { } +func (bs *BrokerStats) String() string { + return fmt.Sprintf("BrokerStats{TopicPartitionCount:%d, ConsumerCount:%d, CpuUsagePercent:%d, Stats:%+v}", + bs.TopicPartitionCount, bs.ConsumerCount, bs.CpuUsagePercent, bs.Stats.Items()) +} + type TopicPartition struct { Namespace string Topic string |