Maintains a persistent websocket connection to the sequencer Gets events that it subscribed for.

Takes item from input channel and in parallel puts to all output channels.

Accepts slices of elements and emits each element individually.

Processing task.

Takes elements from multiple channels and sends them to a single channel Each channel may take assume and give up control of the output channel by sending messages Passed messages have to implement the interface JoinController for this to work.

Takes item from input channel, processes it and inserts it into the output channel.

Implements a two step processing task: - onProcess is called for each incoming data item for pre processing - onFlush is called periodically to handle a batch of processed data.

Implement operation retrying.

Store handles saving data to the database in na robust way.

Boilerplate for running long lived tasks.