flowbber.components.sink

Module implementating the Sink base class.

All custom Flowbber sinks must extend from the Sink class.

Classes

  • Sink: Main base class to implement a Sink.
  • FilterSink: Common sink base class that adds a include and exclude configuration
class flowbber.components.sink.Sink(index, type_, id_, optional=False, timeout=None, config=None)

Main base class to implement a Sink.

Inheritance

Inheritance diagram of Sink

distribute(data)

Distribute the collected data.

All sinks subclasses must implement this abstract method.

Parameters
data (OrderedDict) – The collected data. This dictionary can be modified as required without consequences for the pipeline.
class flowbber.components.sink.FilterSink(index, type_, id_, optional=False, timeout=None, config=None)

Common sink base class that adds a include and exclude configuration options and filters the data before using it.

Inheritance

Inheritance diagram of FilterSink