'orch daemon add rgw',
'name=realm_name,type=CephString '
'name=zone_name,type=CephString '
+ 'name=subcluster,type=CephString,req=false '
+ 'name=port,type=CephInt,req=false '
+ 'name=ssl,type=CephBool,req=false '
'name=placement,type=CephString,req=false',
'Start RGW daemon(s)')
def _rgw_add(self,
realm_name: str,
zone_name: str,
+ subcluster: Optional[str] = None,
+ port: Optional[int] = None,
+ ssl: bool = False,
placement: Optional[str] = None,
inbuf: Optional[str] = None) -> HandleCommandResult:
if inbuf:
spec = RGWSpec(
rgw_realm=realm_name,
rgw_zone=zone_name,
+ subcluster=subcluster,
+ rgw_frontend_port=port,
+ ssl=ssl,
placement=PlacementSpec.from_string(placement),
)
namespace=namespace,
placement=PlacementSpec.from_string(placement),
)
+
spec.validate_add()
completion = self.add_nfs(spec)
self._orchestrator_wait([completion])
'mds', fs_name,
placement=PlacementSpec.from_string(placement),
unmanaged=unmanaged)
+
completion = self.apply_mds(spec)
self._orchestrator_wait([completion])
raise_if_exception(completion)
rgw_realm=realm_name,
rgw_zone=zone_name,
subcluster=subcluster,
- placement=PlacementSpec.from_string(placement),
- unmanaged=unmanaged,
rgw_frontend_port=port,
ssl=ssl,
+ placement=PlacementSpec.from_string(placement),
+ unmanaged=unmanaged,
)
+
completion = self.apply_rgw(spec)
self._orchestrator_wait([completion])
raise_if_exception(completion)
placement=PlacementSpec.from_string(placement),
unmanaged=unmanaged,
)
+
completion = self.apply_nfs(spec)
self._orchestrator_wait([completion])
raise_if_exception(completion)