dispatcher

ChannelFilter

Bases: _DispatcherBase

Wrap another dispatcher and forward a subset of channels by name.

CsvDispatcher

Bases: _DispatcherBase

A fixed-width CSV data target backed by a pre-sized file.

DataFrameDispatcher

Bases: _DispatcherBase

Store collected data in in-memory columns.

DataFrameHandle

Shared handle for reading collected dataframe data.

DecimationDispatcher

Bases: _DispatcherBase

Wrap another dispatcher and forward every Nth row.

LatestValueDispatcher

Bases: _DispatcherBase

Dispatcher that always keeps the latest row available.

LowPassDispatcher

Bases: _DispatcherBase

Wrap another dispatcher and apply a low-pass filter per channel.

TimescaleDbDispatcher

Bases: _DispatcherBase

Write control-loop rows to a TimescaleDB/PostgreSQL table.