- Allow listing services by service_type.
- Allow listing daemons by daemon_type.
Signed-off-by: Kiefer Chang <kiefer.chang@suse.com>
@raise_if_no_orchestrator([OrchFeature.DAEMON_LIST])
def daemons(self, hostname: str) -> List[dict]:
orch = OrchClient.instance()
- daemons = orch.services.list_daemons(None, hostname)
+ daemons = orch.services.list_daemons(hostname=hostname)
return [d.to_json() for d in daemons]
@handle_orchestrator_error('host')
@raise_if_no_orchestrator([OrchFeature.SERVICE_LIST])
def list(self, service_name: Optional[str] = None) -> List[dict]:
orch = OrchClient.instance()
- return [service.to_json() for service in orch.services.list(service_name)]
+ return [service.to_json() for service in orch.services.list(service_name=service_name)]
@raise_if_no_orchestrator([OrchFeature.SERVICE_LIST])
def get(self, service_name: str) -> List[dict]:
@raise_if_no_orchestrator([OrchFeature.DAEMON_LIST])
def daemons(self, service_name: str) -> List[dict]:
orch = OrchClient.instance()
- daemons = orch.services.list_daemons(service_name)
+ daemons = orch.services.list_daemons(service_name=service_name)
return [d.to_json() for d in daemons]
@CreatePermission
class ServiceManager(ResourceManager):
@wait_api_result
- def list(self, service_name: Optional[str] = None) -> List[ServiceDescription]:
- return self.api.describe_service(None, service_name)
+ def list(self,
+ service_type: Optional[str] = None,
+ service_name: Optional[str] = None) -> List[ServiceDescription]:
+ return self.api.describe_service(service_type, service_name)
@wait_api_result
def get(self, service_name: str) -> ServiceDescription:
@wait_api_result
def list_daemons(self,
service_name: Optional[str] = None,
+ daemon_type: Optional[str] = None,
hostname: Optional[str] = None) -> List[DaemonDescription]:
- return self.api.list_daemons(service_name, host=hostname)
+ return self.api.list_daemons(service_name=service_name,
+ daemon_type=daemon_type,
+ host=hostname)
def reload(self, service_type, service_ids):
if not isinstance(service_ids, list):