X-Git-Url: https://git.proxmox.com/?a=blobdiff_plain;f=ceph%2Fsrc%2Fpybind%2Fmgr%2Forchestrator%2F_interface.py;h=47009f4f4151fb1847fc95e78a4f0da6f73b3d5b;hb=39ae355f72b1d71f2212a99f2bd9f6c1e0d35528;hp=6f0374ffede94dc1c0571981ee5af61ac10986aa;hpb=e04241aa9b639588fa6c864845287d2824cb6b55;p=ceph.git diff --git a/ceph/src/pybind/mgr/orchestrator/_interface.py b/ceph/src/pybind/mgr/orchestrator/_interface.py index 6f0374ffe..47009f4f4 100644 --- a/ceph/src/pybind/mgr/orchestrator/_interface.py +++ b/ceph/src/pybind/mgr/orchestrator/_interface.py @@ -475,6 +475,7 @@ class Orchestrator(object): 'mon': self.apply_mon, 'nfs': self.apply_nfs, 'node-exporter': self.apply_node_exporter, + 'ceph-exporter': self.apply_ceph_exporter, 'osd': lambda dg: self.apply_drivegroups([dg]), # type: ignore 'prometheus': self.apply_prometheus, 'loki': self.apply_loki, @@ -655,6 +656,10 @@ class Orchestrator(object): """Update existing a Node-Exporter daemon(s)""" raise NotImplementedError() + def apply_ceph_exporter(self, spec: ServiceSpec) -> OrchResult[str]: + """Update existing a ceph exporter daemon(s)""" + raise NotImplementedError() + def apply_loki(self, spec: ServiceSpec) -> OrchResult[str]: """Update existing a Loki daemon(s)""" raise NotImplementedError() @@ -764,6 +769,7 @@ def daemon_type_to_service(dtype: str) -> str: 'alertmanager': 'alertmanager', 'prometheus': 'prometheus', 'node-exporter': 'node-exporter', + 'ceph-exporter': 'ceph-exporter', 'loki': 'loki', 'promtail': 'promtail', 'crash': 'crash', @@ -793,6 +799,7 @@ def service_to_daemon_types(stype: str) -> List[str]: 'loki': ['loki'], 'promtail': ['promtail'], 'node-exporter': ['node-exporter'], + 'ceph-exporter': ['ceph-exporter'], 'crash': ['crash'], 'container': ['container'], 'agent': ['agent'], @@ -891,6 +898,7 @@ class DaemonDescription(object): rank: Optional[int] = None, rank_generation: Optional[int] = None, extra_container_args: Optional[List[str]] = None, + extra_entrypoint_args: Optional[List[str]] = None, ) -> None: #: Host is at the same granularity as InventoryHost @@ -956,6 +964,7 @@ class DaemonDescription(object): self.is_active = is_active self.extra_container_args = extra_container_args + self.extra_entrypoint_args = extra_entrypoint_args @property def status(self) -> Optional[DaemonDescriptionStatus]: