@rest_initialiser(cluster_init_check=True, version_check=True)
def execute(self, opts):
    (status, errors) = self.rest.rebalance_status()
    _exit_if_errors(errors)
    print(json.dumps(status, indent=2))
@rest_initialiser(cluster_init_check=True, version_check=True)
def execute(self, opts):
    (status, errors) = self.rest.rebalance_status()
    _exit_if_errors(errors)
    print(json.dumps(status, indent=2))