plugins/OpenStack/Aodh/plugin_instance.py

   1 # Copyright 2017 Intel Research and Development Ireland Limited
   2 # *************************************************************
   3
   4 # This file is part of OSM Monitoring module
   5 # All Rights Reserved to Intel Corporation
   6
   7 # Licensed under the Apache License, Version 2.0 (the "License"); you may
   8 # not use this file except in compliance with the License. You may obtain
   9 # a copy of the License at
  10
  11 #         http://www.apache.org/licenses/LICENSE-2.0
  12
  13 # Unless required by applicable law or agreed to in writing, software
  14 # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
  15 # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
  16 # License for the specific language governing permissions and limitations
  17 # under the License.
  18
  19 # For those usages not covered by the Apache License, Version 2.0 please
  20 # contact: helena.mcgough@intel.com or adrian.hoban@intel.com
  21 ##
  22 """Aodh plugin for the OSM monitoring module."""
  23
  24 import logging as log
  25 # import sys
  26
  27 # path = "/opt/stack/MON"
  28 # if path not in sys.path:
  29 #    sys.path.append(path)
  30
  31 from plugins.OpenStack.Aodh.alarming import Alarming
  32 from plugins.OpenStack.Aodh.notifier import Notifier
  33 from plugins.OpenStack.settings import Config
  34
  35 __author__ = "Helena McGough"
  36
  37
  38 def register_plugin():
  39     """Register the plugin."""
  40     # Initialize configuration and notifications
  41     config = Config.instance()
  42     notifier = Notifier.instance()
  43
  44     # Intialize plugin
  45     instance = Plugin(config=config, notifier=notifier)
  46     instance.config()
  47     instance.alarm()
  48     instance.notify()
  49
  50
  51 class Plugin(object):
  52     """Aodh plugin for OSM MON."""
  53
  54     def __init__(self, config, notifier):
  55         """Plugin instance."""
  56         log.info("Initialze the plugin instance.")
  57         self._config = config
  58         self._alarming = Alarming()
  59         self._notifier = notifier
  60
  61     def config(self):
  62         """Configure plugin."""
  63         log.info("Configure the plugin instance.")
  64         self._config.read_environ("aodh")
  65
  66     def alarm(self):
  67         """Allow alarm info to be received from Aodh."""
  68         log.info("Begin alarm functionality.")
  69         self._alarming.alarming()
  70
  71     def notify(self):
  72         """Send notifications to the SO."""
  73         # TODO(mcgoughh): Run simultaneously so that notifications
  74         # can be sent while messages are being consumed
  75         log.info("Sending Openstack notifications to the SO.")
  76         self._notifier.notify(self._alarming)
  77
  78 register_plugin()