This module contains classes and functions for classifying power outages.

Modules
		config datetime mongo multiprocessing protobuf

Classes
		plugins.base_plugin.MaukaPlugin(builtins.object) OutagePlugin   class OutagePlugin(plugins.base_plugin.MaukaPlugin)     OutagePlugin(conf: config.MaukaConfig, exit_event: &lt;bound method BaseContext.Event of &lt;multiprocessing.context.DefaultContext object at 0x1037fcb00&gt;&gt;)   This plugin identifies power outages by keeping track of the health collection for box status.     Method resolution order: OutagePlugin plugins.base_plugin.MaukaPlugin builtins.object Methods defined here: __init__(self, conf: config.MaukaConfig, exit_event: <bound method BaseContext.Event of <multiprocessing.context.DefaultContext object at 0x1037fcb00>>) Initializes the base plugin   :param conf: Configuration dictionary :param subscriptions: List of subscriptions this plugin should subscribe to :param name: The name of this plugin on_message(self, topic: str, mauka_message: mauka_pb2.MaukaMessage) This gets called when a subscriber receives a message from a topic they are subscribed too.   This should be implemented in all subclasses.   :param topic: The topic this message is associated with :param mauka_message: The message contents Data and other attributes defined here: NAME = 'OutagePlugin' Methods inherited from plugins.base_plugin.MaukaPlugin: debug(self, msg: str) Prints a debug message using this classes logger and formatted the plugin name. :param msg: Message to print to debug. get_mongo_client(self) Returns an OPQ mongo client   :return: An OPQ mongo client get_status(self) -> str Return the status of this plugin :return: The status of this plugin handle_self_message(self, message: str) Handles a self-message   :param message: The message to handle is_self_message(self, topic: str) -> bool Determines if this is a message directed at this plugin. I.e. the topic is the name of the plugin.   :param topic: Topic of the message :return: If this is a self message or not produce(self, topic: str, mauka_message: mauka_pb2.MaukaMessage) Produces a message with a given topic to the system   :param topic: The topic to produce this message to :param mauka_message: The message to produce run_plugin(self) This is the run loop for this plugin process start_heartbeat(self) This is a recursive function that acts as a heartbeat.   This function calls itself over-and-over on a timer to produce heartbeat messages. The interval can be configured is the configuration file. Data descriptors inherited from plugins.base_plugin.MaukaPlugin: __dict__ dictionary for instance variables (if defined) __weakref__ list of weak references to the object (if defined)

Functions
		is_unplugged(mongo_client: mongo.OpqMongoClient, box_id: str) -> bool Checks the mongo database to determine if a device is marked as unplugged or not. :param mongo_client: An instance of a opq mongo client. :param box_id: The id of the box to check for. :return: Whether or not the box is unplugged. If a box can't be found or a value is not there then defaults True. unix_time_millis(date_time: <module 'datetime' from '/usr/local/Cellar/python/3.7.2_1/Frameworks/Python.framework/Versions/3.7/lib/python3.7/datetime.py'>) -> float Turns a datetime into milliseconds since epoch. The datedate must already be in the timezone UTC. :param date_time: The datetime to convert to epoch. :return: The number of milliseconds since the epoch.

Data
		BOX_STATUS_DOWN = 'DOWN' BOX_STATUS_UP = 'UP' EPOCH = datetime.datetime(1970, 1, 1, 0, 0)