Merge "Updated Kafka producer. This producer has the following changes:"
[osm/MON.git] / plugins / OpenStack / Aodh / plugin_instance.py
1 """Aodh plugin for the OSM monitoring module."""
2
3 import logging as log
4 #import sys
5
6 #path = "/home/stack/MON"
7 #if path not in sys.path:
8 # sys.path.append(path)
9
10 from plugins.OpenStack.Aodh.alarming import Alarming
11 from plugins.OpenStack.settings import Config
12
13
14 def register_plugin():
15 """Register the plugin."""
16 config = Config.instance()
17 instance = Plugin(config=config)
18 instance.config()
19 instance.alarm()
20
21
22 class Plugin(object):
23 """Aodh plugin for OSM MON."""
24
25 def __init__(self, config):
26 """Plugin instance."""
27 log.info("Initialze the plugin instance.")
28 self._config = config
29 self._alarm = Alarming()
30
31 def config(self):
32 """Configure plugin."""
33 log.info("Configure the plugin instance.")
34 self._config.read_environ("aodh")
35
36 def alarm(self):
37 """Allow alarm info to be received from Aodh."""
38 log.info("Begin alarm functionality.")
39 self._alarm.alarming()
40
41 register_plugin()