The panko.event.storage.base Module

class panko.event.storage.base.Connection(url, conf)[source]

Bases: object

Base class for event storage system connections.

static clear()[source]

Clear database.

static clear_expired_event_data(ttl)[source]

Clear expired data from the backend storage system.

Clearing occurs according to the time-to-live.

Parameters:ttl – Number of seconds to keep records for.
classmethod get_capabilities()[source]

Return an dictionary with the capabilities of each driver.

static get_event_types()[source]

Return all event types as an iterable of strings.

static get_events(event_filter, limit=None)[source]

Return an iterable of model.Event objects.

classmethod get_storage_capabilities()[source]

Return a dictionary representing the performance capabilities.

This is needed to evaluate the performance of each driver.

static get_trait_types(event_type)[source]

Return a dictionary containing the name and data type of the trait.

Only trait types for the provided event_type are returned. :param event_type: the type of the Event

static get_traits(event_type, trait_type=None)[source]

Return all trait instances associated with an event_type.

If trait_type is specified, only return instances of that trait type. :param event_type: the type of the Event to filter by :param trait_type: the name of the Trait to filter by

static record_events(events)[source]

Write the events to the backend storage system.

Parameters:events – a list of model.Event objects.
static upgrade()[source]

Migrate the database to version or the most recent version.

Previous topic

The panko.dispatcher.database Module

Next topic

The panko.event.storage.impl_elasticsearch Module

Project Source

This Page