aboutsummaryrefslogtreecommitdiff
path: root/weed/shell/command_mq_balance.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2024-09-28 20:22:57 -0700
committerchrislu <chris.lu@gmail.com>2024-09-28 20:23:01 -0700
commit701abbb9df1b21b2acef8af6b5f1093754dd4f40 (patch)
tree631280df2bf1a541390df0f1683410b93b96b17c /weed/shell/command_mq_balance.go
parentdad3a26fb6a114e8b689ae60935e5f48d29cdd14 (diff)
downloadseaweedfs-701abbb9df1b21b2acef8af6b5f1093754dd4f40.tar.xz
seaweedfs-701abbb9df1b21b2acef8af6b5f1093754dd4f40.zip
add IsResourceHeavy() to command interface
Diffstat (limited to 'weed/shell/command_mq_balance.go')
-rw-r--r--weed/shell/command_mq_balance.go4
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/shell/command_mq_balance.go b/weed/shell/command_mq_balance.go
index dbe218b54..af79bba2d 100644
--- a/weed/shell/command_mq_balance.go
+++ b/weed/shell/command_mq_balance.go
@@ -25,6 +25,10 @@ func (c *commandMqBalanceTopics) Help() string {
`
}
+func (c *commandMqBalanceTopics) IsResourceHeavy() bool {
+ return false
+}
+
func (c *commandMqBalanceTopics) Do(args []string, commandEnv *CommandEnv, writer io.Writer) error {
// find the broker balancer