Struct FlowManager 

pub struct FlowManager { /* private fields */ }

The Tier 2 flow manager: opens and resumes durable flows over a Journal, running each step’s effect through the Tier 1 Engine. One per process, &self-concurrent; hands out a &mut FlowHandle per running flow.

Implementations

impl FlowManager

pub fn new( engine: Arc<Engine>, journal: Arc<dyn Journal>, clock: Arc<dyn Clock>, holder: ProcessId, ) -> Self

A manager with the default FlowConfig.

pub fn with_config( engine: Arc<Engine>, journal: Arc<dyn Journal>, clock: Arc<dyn Clock>, holder: ProcessId, config: FlowConfig, ) -> Self

A manager with explicit tuning.

pub fn enter_flow(&self, desc: &FlowDescriptor) -> Result<FlowHandle, KeelError>

Enter (begin or resume) the flow with this identity: open the row (idempotent), take the lease, and hand back a handle in replay-or-live mode. Err when the lease is held by a live holder (KEEL-E030) or the flow is already dead (KEEL-E032).

Errors

• KEEL-E030 if another holder’s lease is still valid.
• KEEL-E032 if the flow is dead (never auto-resumed).
• KEEL-E040 if the journal cannot open the flow row.

pub fn resume_flow( &self, flow: &FlowDescriptor, current_code_hash: Option<&str>, ) -> Result<FlowHandle, KeelError>

Resume a flow the recovery scan surfaced (Journal::incomplete_flows), fencing against the currently-deployed code_hash.

Errors

As enter_flow.

Trait Implementations

impl Debug for FlowManager

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

Formats the value using the given formatter.