Skip to main content

Module supervisor

Module supervisor 

Source
Expand description

Supervisor: top-level task tree that owns and restarts replication workers.

The FlowSupervisor turns a validated ReplicatorConfig into one running FlowWorker per flow, then runs a background supervision loop that restarts any worker whose connect runtime has entered [RuntimeState::Failed].

Structsยง

FlowSupervisor
Control plane that owns and supervises the per-flow replication workers.