with self._with_host(cephadm_module, 'test'):
ps = PlacementSpec(hosts=['test'], count=1)
- c = cephadm_module.add_rgw(RGWSpec('realm', 'zone', placement=ps))
+ c = cephadm_module.add_rgw(RGWSpec(rgw_realm='realm', rgw_zone='zone', placement=ps))
[out] = wait(cephadm_module, c)
match_glob(out, "Deployed rgw.realm.zone.* on host 'test'")
with self._with_host(cephadm_module, 'host1'):
with self._with_host(cephadm_module, 'host2'):
ps = PlacementSpec(hosts=['host1'], count=1)
- c = cephadm_module.add_rgw(RGWSpec('realm', 'zone1', placement=ps))
+ c = cephadm_module.add_rgw(RGWSpec(rgw_realm='realm', rgw_zone='zone1', placement=ps))
[out] = wait(cephadm_module, c)
match_glob(out, "Deployed rgw.realm.zone1.host1.* on host 'host1'")
ps = PlacementSpec(hosts=['host1', 'host2'], count=2)
- r = cephadm_module._apply_service(RGWSpec('realm', 'zone1', placement=ps))
+ r = cephadm_module._apply_service(RGWSpec(rgw_realm='realm', rgw_zone='zone1', placement=ps))
assert r
@mock.patch("cephadm.module.CephadmOrchestrator._run_cephadm", _run_cephadm(
"""
def __init__(self,
+ service_type='rgw',
+ service_id=None, # type: Optional[str]
+ placement=None,
rgw_realm=None, # type: Optional[str]
rgw_zone=None, # type: Optional[str]
subcluster=None, # type: Optional[str]
- service_id=None, # type: Optional[str]
- placement=None,
- service_type='rgw',
rgw_frontend_port=None, # type: Optional[int]
unmanaged=False, # type: bool
ssl=False, # type: bool
):
- assert service_type == 'rgw'
+ assert service_type == 'rgw', service_type
if service_id:
a = service_id.split('.', 2)
rgw_realm = a[0]