projects
/
osm
/
MON.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Updated Kafka producer. This producer has the following changes:
[osm/MON.git]
/
plugins
/
OpenStack
/
Aodh
/
plugin_instance.py
diff --git
a/plugins/OpenStack/Aodh/plugin_instance.py
b/plugins/OpenStack/Aodh/plugin_instance.py
index
8096f3f
..
22db409
100644
(file)
--- a/
plugins/OpenStack/Aodh/plugin_instance.py
+++ b/
plugins/OpenStack/Aodh/plugin_instance.py
@@
-1,14
+1,9
@@
"""Aodh plugin for the OSM monitoring module."""
"""Aodh plugin for the OSM monitoring module."""
-import sys
-import logging
+import logging as log
-path = "/home/stack/MON"
-if path not in sys.path:
- sys.path.append(path)
-
-from plugins.Openstack.Aodh.alarming import Alarming
-from plugins.Openstack.settings import Config
+from plugins.OpenStack.Aodh.alarming import Alarming
+from plugins.OpenStack.settings import Config
def register_plugin():
def register_plugin():
@@
-24,15
+19,18
@@
class Plugin(object):
def __init__(self, config):
"""Plugin instance."""
def __init__(self, config):
"""Plugin instance."""
+ log.info("Initialze the plugin instance.")
self._config = config
self._alarm = Alarming()
def config(self):
"""Configure plugin."""
self._config = config
self._alarm = Alarming()
def config(self):
"""Configure plugin."""
+ log.info("Configure the plugin instance.")
self._config.read_environ()
def alarm(self):
"""Allow alarm info to be received from Aodh."""
self._config.read_environ()
def alarm(self):
"""Allow alarm info to be received from Aodh."""
+ log.info("Begin alarm functionality.")
self._alarm.alarming()
register_plugin()
self._alarm.alarming()
register_plugin()