]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
mgr/orchestrator: change "daemon_name" field in ServiceDescription to be "service_ins...
authorJeff Layton <jlayton@redhat.com>
Thu, 17 Jan 2019 13:46:23 +0000 (08:46 -0500)
committerJeff Layton <jlayton@redhat.com>
Thu, 17 Jan 2019 13:47:25 +0000 (08:47 -0500)
Signed-off-by: Jeff Layton <jlayton@redhat.com>
src/pybind/mgr/deepsea/module.py
src/pybind/mgr/orchestrator.py
src/pybind/mgr/orchestrator_cli/module.py
src/pybind/mgr/rook/module.py
src/pybind/mgr/test_orchestrator/module.py

index 29ef6ab38d0f18f851fca43785cbacfaa1376540..344770be6e8958d612774a5505f495e97dbdeebb 100644 (file)
@@ -183,10 +183,10 @@ class DeepSeaOrchestrator(MgrModule, orchestrator.Orchestrator):
             result = []
             if event_data['success']:
                 for node_name, service_info in event_data["return"].items():
-                    for service_type, daemon_name in service_info.items():
+                    for service_type, service_instance in service_info.items():
                         desc = orchestrator.ServiceDescription()
                         desc.nodename = node_name
-                        desc.daemon_name = daemon_name
+                        desc.service_instance = service_instance
                         desc.service_type = service_type
                         result.append(desc)
             return result
index 4e234d17b7d3f4e38747f9dd561a2c5414034230..1c0855c8b04f4b6c96d41202b69466b59e1b3aeb 100644 (file)
@@ -410,7 +410,7 @@ class ServiceDescription(object):
         # typically either based on hostnames or on pod names.
         # This is the <foo> in mds.<foo>, the ID that will appear
         # in the FSMap/ServiceMap.
-        self.daemon_name = None
+        self.service_instance = None
 
         # The type of service (osd, mon, mgr, etc.)
         self.service_type = None
@@ -436,7 +436,7 @@ class ServiceDescription(object):
         out = {
             'nodename': self.nodename,
             'container_id': self.container_id,
-            'daemon_name': self.daemon_name,
+            'service_instance': self.service_instance,
             'service_type': self.service_type,
             'version': self.version,
             'rados_config_location': self.rados_config_location,
index 51b06a6c8376628410becac4a4004124af298f5b..17aed3225972a9598d8641dd375f9301a314d312 100644 (file)
@@ -191,7 +191,7 @@ class OrchestratorCli(orchestrator.OrchestratorClientMixin, MgrModule):
         services = completion.result
 
         # Sort the list for display
-        services.sort(key=lambda s: (s.service_type, s.nodename, s.daemon_name))
+        services.sort(key=lambda s: (s.service_type, s.nodename, s.service_instance))
 
         if len(services) == 0:
             return HandleCommandResult(stdout="No services reported")
@@ -203,7 +203,7 @@ class OrchestratorCli(orchestrator.OrchestratorClientMixin, MgrModule):
             for s in services:
                 lines.append("{0}.{1} {2} {3} {4} {5}".format(
                     s.service_type,
-                    s.daemon_name,
+                    s.service_instance,
                     s.nodename,
                     s.container_id,
                     s.version,
index 9e56c94d01eb2f5ed4b78bbd210384eb18fcac70..cb9d2b053d2d2fb9a39446c4a86a7ecb8ccaaf6e 100644 (file)
@@ -346,16 +346,16 @@ class RookOrchestrator(MgrModule, orchestrator.Orchestrator):
             sd.service_type = p['labels']['app'].replace('rook-ceph-', '')
 
             if sd.service_type == "osd":
-                sd.daemon_name = "%s" % p['labels']["ceph-osd-id"]
+                sd.service_instance = "%s" % p['labels']["ceph-osd-id"]
             elif sd.service_type == "mds":
-                sd.daemon_name = p['labels']["rook_file_system"]
+                sd.service_instance = p['labels']["rook_file_system"]
             elif sd.service_type == "mon":
-                sd.daemon_name = p['labels']["mon"]
+                sd.service_instance = p['labels']["mon"]
             elif sd.service_type == "mgr":
-                sd.daemon_name = p['labels']["mgr"]
+                sd.service_instance = p['labels']["mgr"]
             elif sd.service_type == "nfs":
-                sd.daemon_name = p['labels']["ceph_nfs"]
-                sd.rados_config_location = self.rook_cluster.get_nfs_conf_url(sd.daemon_name, p['labels']['instance'])
+                sd.service_instance = p['labels']["ceph_nfs"]
+                sd.rados_config_location = self.rook_cluster.get_nfs_conf_url(sd.service_instance, p['labels']['instance'])
             else:
                 # Unknown type -- skip it
                 continue
index 88b3391acd10767418f74d88563b8afe6cd75cc9..c9f540de8f0b8995fda3b7f9014c82ec196cea65 100644 (file)
@@ -238,7 +238,7 @@ class TestOrchestrator(MgrModule, orchestrator.Orchestrator):
         for p in processes:
             sd = orchestrator.ServiceDescription()
             sd.nodename = 'localhost'
-            sd.daemon_name = re.search('ceph-[^ ]+', p).group()
+            sd.service_instance = re.search('ceph-[^ ]+', p).group()
             result.append(sd)
 
         return result