Struct Workflow 

pub struct Workflow<A: Address, K, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = WorkflowOutcome<K>>>> { /* private fields */ }

Deterministic dependency-ordered workflow coordinator.

Construction validates a finite acyclic graph. Start activates every root in definition order. Completion activates a blocked step exactly once when all of its prerequisites are complete. Unknown, blocked, duplicate, and post-start terminal input is explicitly rejected without mutation. Completion or failure input before Start is returned as a typed WorkflowError::NotStarted because no result route has been established. Failure and cancellation are terminal and prevent later activation. Initialization is empty and the actor itself remains available to report terminal rejection. Graph validation, one-run retention, activation ordering, and terminal policy are Bombay choices. The actor model requires only that each event be processed as one transition; participant execution and durable saga state belong to the Driver/Mnesis boundaries. No transition panics.

Implementations

impl<A, K, Route> Workflow<A, K, Route>

where A: Address, K: Clone + Eq, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = WorkflowOutcome<K>>> + Clone,

pub fn new( definition: WorkflowDefinition<K>, ) -> Result<Self, WorkflowConfigError<K>>

Validate and retain one dependency graph.

Errors

Returns a concrete WorkflowConfigError for empty, duplicate, unknown, self-dependent, or cyclic definitions.

pub const fn definition(&self) -> &WorkflowDefinition<K>

Borrow the validated definition.

pub const fn state(&self) -> &WorkflowState<K, Route>

Borrow the complete workflow phase.

Trait Implementations

impl<A, K, Route> Behavior for Workflow<A, K, Route>

where A: Address, K: Clone + Eq, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = WorkflowOutcome<K>>> + Clone, Route::Sends: SendsFor<User<A, WorkflowMessage<K, Route>>>,

type Protocol = Workflow<A, K, Route>

Stable public communication identity owned by this actor template.

type Event = User<A, <<Workflow<A, K, Route> as Behavior>::Protocol as Protocol>::Msg>

type Sends = <Route as DeliveryRoute>::Sends

type Ph = Never

type Error = WorkflowError<K>

type Birth = NoBirths

fn transition( &mut self, _: ActiveTurn, event: Self::Event, ) -> BehaviorActed<Self>

Fold exactly one event into explicit actions and the next behavior.

fn init( &mut self, _turn: InitializationTurn, ) -> Result<Actions<<Self::Protocol as Protocol>::Addr, Self::Ph, Self::Sends, Self::Birth>, Self::Error>

where Self: Sized,

Produce initialization actions before the first event is accepted.

fn layer<L>(self, layer: L) -> <L as BehaviorLayer<Self>>::Output

where Self: Sized, L: BehaviorLayer<Self>,

Apply one statically dispatched construction layer.

impl<A, K, Route> BehaviorBase for Workflow<A, K, Route>

where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = WorkflowOutcome<K>>>,

type Base = Workflow<A, K, Route>

fn base(&self) -> &Self

impl<A, K, Route> Protocol for Workflow<A, K, Route>

where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = WorkflowOutcome<K>>>,

type Addr = A

type Msg = WorkflowMessage<K, Route>