Struct FlowRuntime 

pub struct FlowRuntime { /* private fields */ }

The main flow execution runtime

Implementations

impl FlowRuntime

pub fn new( flows: Vec<CompiledFlow>, event_log: Arc<dyn EventLog>, link_service: Arc<dyn LinkService>, entity_fetchers: HashMap<String, Arc<dyn EntityFetcher>>, ) -> Self

Create a new FlowRuntime

pub fn with_consumer_name(self, name: impl Into<String>) -> Self

Set a custom consumer name (for multi-consumer setups)

pub fn with_sink_registry(self, registry: Arc<SinkRegistry>) -> Self

Set the sink registry for deliver operators

Without a sink registry, the deliver operator will log but not actually dispatch to any sink.

pub fn run(self, position: SeekPosition) -> JoinHandle<()>

Start the runtime as a background task

Returns a JoinHandle that resolves when the runtime stops. The runtime runs indefinitely, processing events as they arrive.

Trait Implementations

impl Debug for FlowRuntime

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.