Struct FlowManager 

pub struct FlowManager { /* private fields */ }

High-level operational surface for managed flows.

Every mutation method follows the same template: read current flow, validate the requested state machine transition, persist via update_with_revision, append an audit event. RevisionMismatch errors trigger a single re-fetch + retry; persistent contention surfaces to the caller.

Implementations

impl FlowManager

pub fn new(store: Arc<dyn FlowStore>) -> Self

pub async fn create_managed( &self, input: CreateManagedInput, ) -> Result<Flow, FlowError>

Insert a fresh flow in Created status. Caller receives the canonical record with assigned id/timestamps.

pub async fn get(&self, id: Uuid) -> Result<Option<Flow>, FlowError>

pub async fn list_by_owner(&self, owner: &str) -> Result<Vec<Flow>, FlowError>

pub async fn list_by_status( &self, status: FlowStatus, ) -> Result<Vec<Flow>, FlowError>

pub async fn start_running(&self, id: Uuid) -> Result<Flow, FlowError>

Created → Running.

pub async fn set_waiting( &self, id: Uuid, wait_json: Value, ) -> Result<Flow, FlowError>

Running → Waiting. wait_json describes what the flow is blocked on (timer deadline, NATS subject, manual signal). Inspected by the wait/resume engine in 14.4.

pub async fn resume( &self, id: Uuid, state_patch: Option<Value>, ) -> Result<Flow, FlowError>

Waiting → Running. Clears wait_json. Optional state_patch merges shallowly into state_json so callers can record what unblocked them.

pub async fn finish( &self, id: Uuid, final_state: Option<Value>, ) -> Result<Flow, FlowError>

Running → Finished. Optional final state patch is merged before transition.

pub async fn fail( &self, id: Uuid, reason: impl Into<String>, ) -> Result<Flow, FlowError>

Running/Waiting → Failed. reason is recorded in the event log and stamped under state_json.failure.

pub async fn request_cancel(&self, id: Uuid) -> Result<Flow, FlowError>

Set sticky cancel intent without changing status. Useful when an in-flight step needs to drain before the flow can flip to Cancelled.

pub async fn cancel(&self, id: Uuid) -> Result<Flow, FlowError>

Force the flow to Cancelled. Allowed from any non-terminal status.

pub async fn update_state( &self, id: Uuid, patch: Value, next_step: Option<String>, ) -> Result<Flow, FlowError>

Mutate state_json without changing status. current_step is optionally updated in the same revision.

pub async fn create_mirrored( &self, input: CreateManagedInput, ) -> Result<Flow, FlowError>

Create a mirrored flow. The flow is born in Running status because the externally-observed work is typically already in flight. Use record_step_observation to keep its steps in sync.

pub async fn record_step_observation( &self, observation: StepObservation, ) -> Result<FlowStep, FlowError>

Upsert-style: if a step with the same (flow_id, run_id) exists, update its status/result; otherwise insert a fresh step row. Designed to be called from a NATS subscriber (or CLI/cron bridge).

pub async fn list_steps( &self, flow_id: Uuid, ) -> Result<Vec<FlowStep>, FlowError>

Read all steps linked to a flow, ordered oldest-first.

Trait Implementations

impl Clone for FlowManager

fn clone(&self) -> FlowManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.