import os
sys.path.append("/root/MON")
-sys.path.append("../../plugins/CloudWatch")
logging.basicConfig(filename='MON_plugins.log',
format='%(asctime)s %(message)s',
from osm_mon.plugins.OpenStack.common import Common
from osm_mon.plugins.OpenStack.Gnocchi import metrics
-from plugin_alarm import plugin_alarms
-from plugin_metric import plugin_metrics
+from osm_mon.plugins.CloudWatch.plugin_alarm import plugin_alarms
+from osm_mon.plugins.CloudWatch.plugin_metric import plugin_metrics
+
+from osm_mon.plugins.vRealiseOps import plugin_receiver
# Initialize servers
server = {'server': 'localhost:9092'}
cloudwatch_alarms = plugin_alarms()
cloudwatch_metrics = plugin_metrics()
+#Create vROps plugin_receiver class instance
+vrops_rcvr = plugin_receiver.PluginReceiver()
+
def get_vim_type(message):
"""Get the vim type that is required by the message."""
try:
if message.topic == "metric_request":
# Check the vim desired by the message
vim_type = get_vim_type(message)
-
+
if vim_type == "openstack":
log.info("This message is for the OpenStack plugin.")
openstack_metrics.metric_calls(
cloudwatch_metrics.metric_calls(message)
log.info("This message is for the CloudWatch plugin.")
- elif vim_type == "vrops":
- log.info("This message is for the vROPs plugin.")
+ elif vim_type == "vmware":
+ log.info("This metric_request message is for the vROPs plugin.")
+ vrops_rcvr.consume(message)
- else:
+ else:
log.debug("vim_type is misconfigured or unsupported; %s",
vim_type)
cloudwatch_alarms.alarm_calls(message)
log.info("This message is for the CloudWatch plugin.")
- elif vim_type == "vrops":
- log.info("This message is for the vROPs plugin.")
+ elif vim_type == "vmware":
+ log.info("This alarm_request message is for the vROPs plugin.")
+ vrops_rcvr.consume(message)
else:
log.debug("vim_type is misconfigured or unsupported; %s",
#TODO Access credentials later
log.info("This message is for the CloudWatch plugin.")
- elif vim_type == "vrops":
- log.info("This message is for the vROPs plugin.")
+ elif vim_type == "vmware":
+ log.info("This access_credentials message is for the vROPs plugin.")
+ vrops_rcvr.consume(message)
else:
log.debug("vim_type is misconfigured or unsupported; %s",