@rest_initialiser(cluster_init_check=True, version_check=True)
def execute(self, opts):
    servers = apply_default_port(opts.servers)
    for server in servers:
        (_, errors) = self.rest.recovery(server, opts.recovery_type)
        _exit_if_errors(errors)
    _success('Servers recovered')
@rest_initialiser(cluster_init_check=True, version_check=True)
def execute(self, opts):
    servers = apply_default_port(opts.servers)
    for server in servers:
        (_, errors) = self.rest.recovery(server, opts.recovery_type)
        _exit_if_errors(errors)
    _success('Servers recovered')