RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-16 07:17:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

mgr/orchestrator_cli: rearrange things a bit

Browse Source 
Group services together

Signed-off-by: Sage Weil <sage@redhat.com>
This commit is contained in:
Sage Weil 2019-11-08 11:26:49 -06:00
parent b0e1ff5efc
commit 5122d323c4
1 changed files with 34 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
src/pybind/mgr/orchestrator_cli/module.py
View File

@ -382,6 +382,15 @@ Usage:
orchestrator.raise_if_exception(completion)
return HandleCommandResult(stdout=completion.result_str())
@_write_cli('orchestrator rbd-mirror rm',
"name=name,type=CephString,req=false",
'Remove rbd-mirror service or rbd-mirror service instance')
def _rbd_mirror_rm(self, name=None):
completion = self.remove_rbd_mirror(name)
self._orchestrator_wait([completion])
orchestrator.raise_if_exception(completion)
return HandleCommandResult(stdout=completion.result_str())
@_write_cli('orchestrator mds add',
"name=fs_name,type=CephString "
"name=num,type=CephInt,req=false "
@ -412,6 +421,15 @@ Usage:
orchestrator.raise_if_exception(completion)
return HandleCommandResult(stdout=completion.result_str())
@_write_cli('orchestrator mds rm',
"name=name,type=CephString",
'Remove an MDS service (mds id or fs_name)')
def _mds_rm(self, name):
completion = self.remove_mds(name)
self._orchestrator_wait([completion])
orchestrator.raise_if_exception(completion)
return HandleCommandResult(stdout=completion.result_str())
@_write_cli('orchestrator rgw add',
'name=zone_name,type=CephString,req=false '
'name=num,type=CephInt,req=false '
@ -459,6 +477,15 @@ Usage:
orchestrator.raise_if_exception(completion)
return HandleCommandResult(stdout=completion.result_str())
@_write_cli('orchestrator rgw rm',
"name=name,type=CephString",
'Remove an RGW service')
def _rgw_rm(self, name):
completion = self.remove_rgw(name)
self._orchestrator_wait([completion])
orchestrator.raise_if_exception(completion)
return HandleCommandResult(stdout=completion.result_str())
@_write_cli('orchestrator nfs add',
"name=svc_arg,type=CephString "
"name=pool,type=CephString "
@ -472,31 +499,14 @@ Usage:
orchestrator.raise_if_exception(completion)
return HandleCommandResult(stdout=completion.result_str())
@_write_cli('orchestrator rbd-mirror rm',
"name=name,type=CephString,req=false",
'Remove rbd-mirror service or rbd-mirror service instance')
def _rbd_mirror_rm(self, name=None):
completion = self.remove_rbd_mirror(name)
@_write_cli('orchestrator nfs update',
"name=svc_id,type=CephString "
"name=num,type=CephInt",
'Scale an NFS service')
def _nfs_update(self, svc_id, num):
spec = orchestrator.NFSServiceSpec(svc_id, count=num)
completion = self.update_nfs(spec)
self._orchestrator_wait([completion])
orchestrator.raise_if_exception(completion)
return HandleCommandResult(stdout=completion.result_str())
@_write_cli('orchestrator mds rm',
"name=name,type=CephString",
'Remove an MDS service (mds id or fs_name)')
def _mds_rm(self, name):
completion = self.remove_mds(name)
self._orchestrator_wait([completion])
orchestrator.raise_if_exception(completion)
return HandleCommandResult(stdout=completion.result_str())
@_write_cli('orchestrator rgw rm',
"name=name,type=CephString",
'Remove an RGW service')
def _rgw_rm(self, name):
completion = self.remove_rgw(name)
self._orchestrator_wait([completion])
orchestrator.raise_if_exception(completion)
return HandleCommandResult(stdout=completion.result_str())
@_write_cli('orchestrator nfs rm',
@ -508,16 +518,6 @@ Usage:
orchestrator.raise_if_exception(completion)
return HandleCommandResult(stdout=completion.result_str())
@_write_cli('orchestrator nfs update',
"name=svc_id,type=CephString "
"name=num,type=CephInt",
'Scale an NFS service')
def _nfs_update(self, svc_id, num):
spec = orchestrator.NFSServiceSpec(svc_id, count=num)
completion = self.update_nfs(spec)
self._orchestrator_wait([completion])
return HandleCommandResult(stdout=completion.result_str())
@_write_cli('orchestrator service',
"name=action,type=CephChoices,strings=start|stop|reload|restart|redeploy "
"name=svc_type,type=CephString "