forcename=name)
if not did_config:
- self.cephadm_services[service_type].config(spec, daemon_id)
+ self.cephadm_services[service_type].config(spec)
did_config = True
daemon_spec = self.cephadm_services[service_type].make_daemon_spec(
def generate_config(self, daemon_spec: CephadmDaemonDeploySpec) -> Tuple[Dict[str, Any], List[str]]:
raise NotImplementedError()
- def config(self, spec: ServiceSpec, daemon_id: str) -> None:
+ def config(self, spec: ServiceSpec) -> None:
"""
Configure the cluster for this service. Only called *once* per
service apply. Not for every daemon.
def allow_colo(self) -> bool:
return True
- def config(self, spec: ServiceSpec, daemon_id: str) -> None:
+ def config(self, spec: ServiceSpec) -> None:
assert self.TYPE == spec.service_type
assert spec.service_id
def allow_colo(self) -> bool:
return True
- def config(self, spec: RGWSpec, rgw_id: str) -> None: # type: ignore
+ def config(self, spec: RGWSpec) -> None: # type: ignore
assert self.TYPE == spec.service_type
# set rgw_realm and rgw_zone, if present
class IscsiService(CephService):
TYPE = 'iscsi'
- def config(self, spec: IscsiServiceSpec, daemon_id: str) -> None: # type: ignore
+ def config(self, spec: IscsiServiceSpec) -> None: # type: ignore
assert self.TYPE == spec.service_type
assert spec.pool
self.mgr._check_pool_exists(spec.pool, spec.service_name())
del rank_map[rank][gen]
self.mgr.spec_store.save_rank_map(spec.service_name(), rank_map)
- def config(self, spec: NFSServiceSpec, daemon_id: str) -> None: # type: ignore
+ def config(self, spec: NFSServiceSpec) -> None: # type: ignore
from nfs.cluster import create_ganesha_pool
assert self.TYPE == spec.service_type