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
# 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
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,
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")
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,
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
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