planetstack/openstack_observer/backend.py

   1 import threading
   2 import time
   3 from observer.event_loop import PlanetStackObserver
   4 from observer.event_manager import EventListener
   5 from util.logger import Logger, logging
   6 from model_policy import run_policy
   7
   8 logger = Logger(level=logging.INFO)
   9
  10 class Backend:
  11
  12     def run(self):
  13             # start the openstack observer
  14             observer = PlanetStackObserver()
  15             observer_thread = threading.Thread(target=observer.run)
  16             observer_thread.start()
  17
  18             # start model policies thread
  19             model_policy_thread = threading.Thread(target=run_policy)
  20             model_policy_thread.start()
  21
  22             # start event listene
  23             event_manager = EventListener(wake_up=observer.wake_up)
  24             event_manager_thread = threading.Thread(target=event_manager.run)
  25             event_manager_thread.start()
  26