flowbber.loaders.aggregator

Module implementating Aggregator base class.

All custom Flowbber aggregators must extend from the Aggregator class.

Functions

flowbber.loaders.aggregator.register(key)

Register a plugin locally.

This method is expected to be used as a decorator. It allows to register a plugin locally without having to create a full Python package to use entrypoints.

Usage:

from flowbber.loaders import source
from flowbber.components.source import Source

@source.register('my_source')
class MySource(Source):
    def collect(self):
        return {'my_value': 1000}

Same apply for aggregators and sinks.

Classes

class flowbber.loaders.aggregator.AggregatorsLoader

Aggregators plugins loader class.

Inheritance

Inheritance diagram of AggregatorsLoader