def has_placement_changed(self, deps: List[str], spec: ServiceSpec) -> bool:
return False
- # manages_own_next_action allows the CephadmService subclasses
- # to incrementally support using choose_next_action instead of
- # "hard coded" blocks in the _check_daemons function.
- manages_own_next_action = False
-
def choose_next_action(
self,
scheduled_action: utils.Action,
return daemon_spec
- manages_own_next_action = True
-
def choose_next_action(
self,
scheduled_action: utils.Action,
return True
return False
- manages_own_next_action = True
-
def choose_next_action(
self,
scheduled_action: utils.Action,
daemon_spec.deps = self.get_dependencies(self.mgr)
return daemon_spec
- manages_own_next_action = True
-
def choose_next_action(
self,
scheduled_action: utils.Action,
return HandleCommandResult(-errno.EBUSY, '', warn_message)
return HandleCommandResult(0, warn_message, '')
- manages_own_next_action = True
-
def choose_next_action(
self,
scheduled_action: utils.Action,
return '/federate'
return '/prometheus/federate'
- manages_own_next_action = True
-
def choose_next_action(
self,
scheduled_action: utils.Action,
out = f'It is presumed safe to stop {names}'
return HandleCommandResult(0, out, '')
- manages_own_next_action = True
-
def choose_next_action(
self,
scheduled_action: utils.Action,
logger.debug(f"No IP address found in the network {spec.monitoring_networks} on host {host}.")
return monitoring_addr, monitoring_port
- manages_own_next_action = True
-
def choose_next_action(
self,
scheduled_action: utils.Action,