The panko.storage.base Module¶

Base classes for storage engines

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

Bases: object

Base class for event storage system connections.

static clear()[source]¶

Clear database.

static clear_expired_data(ttl)[source]¶

Clear expired data from the backend storage system.

Clearing occurs according to the time-to-live. :param 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, pagination=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.

class panko.storage.base.Model(**kwds)[source]¶

Bases: object

Base class for storage API models.

as_dict()[source]¶