Struct FlowEngine 

pub struct FlowEngine { /* private fields */ }

Implementations

impl FlowEngine

pub async fn new( packs: Vec<Arc<PackRuntime>>, config: Arc<HostConfig>, ) -> Result<FlowEngine, Error>

pub fn with_rollout_ids(self, rollout_ids: RolloutIds) -> FlowEngine

Bind the rollout identifiers of the revision-keyed runtime this engine serves, so every invocation’s telemetry carries deployment/bundle/ revision attribution (C5.4). Called by the Phase-D revision dispatcher when it constructs a revision runtime; tenant-only runtimes leave the default (empty) IDs.

pub fn rollout_ids(&self) -> &RolloutIds

The rollout identifiers bound to this engine (read counterpart to with_rollout_ids). Empty by default for the legacy tenant-only path.

pub fn set_cross_pack_resolver(&mut self, resolver: Arc<dyn CrossPackResolver>)

Set an optional cross-pack resolver for provider.invoke nodes that reference providers in other packs (resolved via capability registry).

pub fn set_remote_dispatch_handler( &mut self, handler: Arc<dyn RemoteDispatchHandler>, )

Set the handler that bridges sorla.call flow nodes into a separate runtime over pub/sub. Constructed by the runner binary when a transport (e.g. NATS) is configured.

pub async fn execute( &self, ctx: FlowContext<'_>, input: Value, ) -> Result<FlowExecution, Error>

pub async fn resume( &self, ctx: FlowContext<'_>, snapshot: FlowSnapshot, input: Value, ) -> Result<FlowExecution, Error>

pub fn flows(&self) -> &[FlowDescriptor]

pub fn flow_by_key( &self, pack_id: &str, flow_id: &str, ) -> Option<&FlowDescriptor>

pub fn flow_by_type(&self, flow_type: &str) -> Option<&FlowDescriptor>

pub fn entry_flow_by_type(&self, flow_type: &str) -> Option<&FlowDescriptor>

Resolve a flow by type, considering only application entrypoint flows.

Used to disambiguate an inbound provider event (routed by flow type, with no explicit pack_id/flow_id) when a pack registers one public entrypoint plus internal helper flows of the same type — the common “dispatcher + sub-flows” shape. Internal flows are only reachable via flow.call, so they must never win a type-only route.

Flows owned by a messaging provider pack (its manifest declares a messaging.* provider) are also excluded: a provider ships its own ingress main/default flow that is plumbing for that provider, not the application. In a multi-provider bundle that flow would otherwise compete with the app’s real entrypoint and make the route ambiguous.

Returns None when zero or more than one application entry flow of the type exists (genuinely ambiguous — the caller must then require a pack_id).

pub fn flow_by_id(&self, flow_id: &str) -> Option<&FlowDescriptor>