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]