StreamManager¶

Defined in dccd.daemon.stream_manager

class StreamManager(config, health=None)[source]

Bases: object

Manage real-time WebSocket collection jobs.

Starts one background thread per (exchange, pair) (or per (exchange, pair, channel) for Bitfinex/Bitmex). Each thread runs indefinitely and is automatically restarted after a crash. A SyncService instance pushes data to remotes periodically.

Parameters:

configCollectorConfig: Daemon configuration (stream_jobs + storage).

start()[source]: Start the sync service and all stream threads.

stop()[source]: Signal all streams and the sync service to stop.