Module runtime 

FlowRuntime — subscribes to EventLog and dispatches events to compiled flows

The FlowRuntime is the main execution engine for declarative event flows. It runs as a background task that:

1. Subscribes to the EventLog (from a configurable seek position)
2. For each incoming event, finds matching flows via EventMatcher
3. Executes the pipeline operators sequentially
4. Handles fan-out by recursively processing sub-pipelines
5. Logs errors without propagating them (one flow’s error doesn’t affect others)

Usage

let runtime = FlowRuntime::new(compiled_flows, event_log, link_service, fetchers);
let handle = runtime.run(SeekPosition::Latest);
// handle is a JoinHandle that can be used to monitor/cancel the runtime

Structs

FlowRuntime

The main flow execution runtime