Monitoring publisher tenant changes
Code changes includes:
disable_monitoring_service.yaml for diabling monitoring of the service.
enable_monitoring_service.yaml for enabling monitoring of the service,
install_monitoring_ceilometer.sh for installing monitoring agent in ceilometer and compute nodes.
Change-Id: I7f8d845cc59786eb25382b51573932fc6c9e5fac
diff --git a/xos/synchronizer/ceilometer/monitoring_agent/generate_pipeline.py b/xos/synchronizer/ceilometer/monitoring_agent/generate_pipeline.py
new file mode 100644
index 0000000..beab6d6
--- /dev/null
+++ b/xos/synchronizer/ceilometer/monitoring_agent/generate_pipeline.py
@@ -0,0 +1,125 @@
+from jinja2 import Environment, FileSystemLoader
+from urlparse import urlparse
+import os
+
+# Capture our current directory
+THIS_DIR = os.path.dirname(os.path.abspath(__file__))
+
+openstack_service_info=[]
+onos_service_info=[]
+class Openstack_Service():
+ def __init__(self,service_name,target):
+ self.service_name=service_name
+ self.target=target
+ self.service_enable=True
+ def update_openstack_service_info(self):
+ if not openstack_service_info:
+ openstack_service_info.append(self)
+ else:
+ for obj in openstack_service_info:
+ openstack_service_info.remove(obj)
+ openstack_service_info.append(self)
+ #openstack_service_info[0].target.append(target)
+
+class Onos_Service():
+ def __init__(self,service_name,target,resources):
+ self.service_name=service_name
+ self.target=target
+ self.resources=resources
+ self.service_enable=True
+ def update_onos_service_info(self):
+ if not onos_service_info:
+ onos_service_info.append(self)
+ else:
+ for obj in onos_service_info:
+ onos_service_info.remove(obj)
+ onos_service_info.append(self)
+ #onos_service_info[0].target.append(target)
+
+def generate_pipeline_yaml_for_openstack(target,Flag):
+ # Create the jinja2 environment.
+ # Notice the use of trim_blocks, which greatly helps control whitespace.
+ op_service=Openstack_Service("OPENSTACK",target)
+ op_service.update_openstack_service_info()
+ parse_target=urlparse(target)
+ host = parse_target.hostname
+ port = parse_target.port
+ with open("pipeline.yaml", 'w') as f:
+ j2_env = Environment(loader=FileSystemLoader(THIS_DIR),
+ trim_blocks=True)
+ context = {
+ 'openstack' : Flag,
+ 'listen_ip_addr': host,
+ 'port_number' : port
+ }
+ fp = j2_env.get_template('pipeline.yaml.j2').render (
+ context)
+ f.write(fp)
+
+def generate_pipeline_yaml_for_onos(target,resources,Flag):
+
+ onos_service=Onos_Service("ONOS",target,resources)
+ onos_service.update_onos_service_info()
+ with open("pipeline.yaml", 'w') as f:
+ j2_env = Environment(loader=FileSystemLoader(THIS_DIR),
+ trim_blocks=True)
+ context = {
+ 'onos' : Flag,
+ 'onos_endpoints' : resources,
+ 'onos_target' : target,
+ 'new_line': '\n',
+ 'new_tab': ' '
+ }
+ fp = j2_env.get_template('pipeline.yaml.j2').render (
+ context)
+ f.write(fp)
+
+def generate_pipeline_yaml_for_openstack_onos(target,Flag):
+
+ op_service=Openstack_Service("OPENSTACK",target)
+ op_service.update_openstack_service_info()
+ parse_target=urlparse(target)
+ host = parse_target.hostname
+ port = parse_target.port
+ with open("pipeline.yaml", 'w') as f:
+ j2_env = Environment(loader=FileSystemLoader(THIS_DIR),
+ trim_blocks=True)
+ context = {
+ 'openstack' : Flag,
+ 'listen_ip_addr': host,
+ 'port_number' : port,
+ 'onos' : Flag,
+ 'onos_endpoints' : onos_service_info[0].resources,
+ 'onos_target' : onos_service_info[0].target,
+ 'new_line': '\n',
+ 'new_tab': ' '
+ }
+ fp = j2_env.get_template('pipeline.yaml.j2').render (
+ context)
+ f.write(fp)
+
+def generate_pipeline_yaml_for_onos_openstack(target,resources,Flag):
+
+ onos_service=Onos_Service("ONOS",target,resources)
+ onos_service.update_onos_service_info()
+
+ parse_target=urlparse(openstack_service_info[0].target)
+ host = parse_target.hostname
+ port = parse_target.port
+
+ with open("pipeline.yaml", 'w') as f:
+ j2_env = Environment(loader=FileSystemLoader(THIS_DIR),
+ trim_blocks=True)
+ context = {
+ 'onos' : Flag,
+ 'onos_endpoints' : resources,
+ 'onos_target' : target,
+ 'new_line': '\n',
+ 'new_tab': ' ',
+ 'openstack' : Flag,
+ 'listen_ip_addr': host,
+ 'port_number' : port
+ }
+ fp = j2_env.get_template('pipeline.yaml.j2').render (
+ context)
+ f.write(fp)