b13bcb7513
- Add PEP8 section to tox.ini - Add hacking to requirements to enforce OpenStack style requirements - Change setup.py to use PBR - Add setup.cfg - Fix formatting issues flagged by flake8 check - Add copyright notices to all remaining files - Update .gitignore file - Bump version number Change-Id: If32d332d3b7800f66fe6ad0f815f178bda739036
111 lines
3.3 KiB
Python
111 lines
3.3 KiB
Python
# -*- encoding: utf-8 -*-
|
|
#
|
|
# Copyright © 2014 Rackspace Hosting.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
import abc
|
|
import six
|
|
|
|
|
|
@six.add_metaclass(abc.ABCMeta)
|
|
class CondenserBase(object):
|
|
"""Base class for Condenser objects
|
|
|
|
Collect data extracted from a Notification by the Distiller, and
|
|
format it into a useful data structure.
|
|
|
|
A simple Condenser may just colect all the traits received into
|
|
a dictionary. More complex ones may build collections of application
|
|
or ORM model objects, or XML document trees.
|
|
|
|
Condensers also have hooks for verification logic, to check that
|
|
all needed traits are present.
|
|
"""
|
|
|
|
def __init__(self, **kw):
|
|
"""Set up the condenser.
|
|
|
|
A new instance of the condenser is passed to the
|
|
distiller for each notification extracted.
|
|
|
|
:param kw: keyword parameters for condenser.
|
|
|
|
"""
|
|
super(CondenserBase, self).__init__()
|
|
|
|
@abc.abstractmethod
|
|
def add_trait(self, name, trait_type, value):
|
|
"""Add a trait
|
|
|
|
Add a trait to the Event data structure being built by this
|
|
condenser. The distiller will call this for each extracted trait.
|
|
|
|
:param name: (string) name of the trait
|
|
:param trait_type: (distiller.Datatype) data type of the trait.
|
|
:param value: Value of the trait (of datatype indicated by trait_type)
|
|
|
|
"""
|
|
|
|
@abc.abstractmethod
|
|
def add_envelope_info(self, event_type, message_id, when):
|
|
"""Add the metadata for this event
|
|
|
|
Add metadata extracted from the notification's
|
|
envelope. The distiller will call this once.
|
|
|
|
:param event_type: (string) Type of event, as a dotted string such as
|
|
"compute.instance.update".
|
|
:param message_id: (string) UUID of notification.
|
|
:param when: (datetime) Timestamp of notification from source system.
|
|
|
|
"""
|
|
|
|
@abc.abstractmethod
|
|
def get_event(self):
|
|
"""Return the Event data structure constructed by this condenser."""
|
|
|
|
@abc.abstractmethod
|
|
def clear(self):
|
|
"""Clear condenser state."""
|
|
|
|
def validate(self):
|
|
"""Check Event against whatever validation logic this condenser has
|
|
|
|
:returns: (bool) True if valid.
|
|
|
|
"""
|
|
return True
|
|
|
|
|
|
class DictionaryCondenser(CondenserBase):
|
|
"""Return event data as a simple python dictionary"""
|
|
|
|
def __init__(self, **kw):
|
|
self.clear()
|
|
super(DictionaryCondenser, self).__init__(**kw)
|
|
|
|
def get_event(self):
|
|
return self.event
|
|
|
|
def clear(self):
|
|
self.event = dict()
|
|
|
|
def add_envelope_info(self, event_type, message_id, when):
|
|
self.event['event_type'] = event_type
|
|
self.event['message_id'] = message_id
|
|
self.event['when'] = when
|
|
|
|
def add_trait(self, name, trait_type, value):
|
|
self.event[name] = value
|