Struct TypedWorkflowAdapter 

pub struct TypedWorkflowAdapter<W, E> { /* private fields */ }

Wraps a typed definition and executor, converting only at the boundary.

Implementations

impl<W, E> TypedWorkflowAdapter<W, E>

pub const fn new(definition: W, executor: E) -> TypedWorkflowAdapter<W, E>

Pairs a definition with its executor.

pub const fn definition(&self) -> &W

The typed definition.

pub const fn executor(&self) -> &E

The typed executor.

Trait Implementations

impl<W, E> Debug for TypedWorkflowAdapter<W, E>

where W: WorkflowDefinition,

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

Formats the value using the given formatter.

impl<W, E> ErasedExecutor for TypedWorkflowAdapter<W, E>

where W: WorkflowDefinition, E: WorkflowExecutor<W>,

fn load<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, account: &'life1 AccountId, case_id: &'life2 CaseId, ) -> Pin<Box<dyn Future<Output = Result<Versioned<Option<Value>>, StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, TypedWorkflowAdapter<W, E>: 'async_trait,

Loads a case for an account as JSON.

fn execute<'life0, 'async_trait>( &'life0 self, batch: CommandBatch<Value>, ) -> Pin<Box<dyn Future<Output = Result<Commit<Value, Value>, ExecutionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, TypedWorkflowAdapter<W, E>: 'async_trait,

Executes an erased batch.

impl<W, E> ErasedWorkflow for TypedWorkflowAdapter<W, E>

where W: WorkflowDefinition, E: Send + Sync,

fn key(&self) -> WorkflowKey

Stable key.

fn version(&self) -> WorkflowVersion

Version.

fn project( &self, case_ref: CaseRef, state: Option<&Value>, ) -> Result<ErasedWorkflowView, ErasureError>

Projects a case.

fn operations( &self, case_ref: CaseRef, state: Option<&Value>, ) -> Result<Vec<OperationSpec>, ErasureError>

The operations offered for this case, validated and stamped with this workflow.

fn summary(&self) -> Option<String>

One line saying what the workflow is for.

fn glossary(&self) -> Vec<GlossaryTerm>

Terms this workflow’s users say, and what they mean here.

fn noun(&self) -> Option<LocalizedText>

What one record of this workflow is called. See WorkflowDefinition::noun.

fn briefing( &self, case_ref: CaseRef, state: Option<&Value>, ) -> Result<Option<String>, ErasureError>

Guidance for understanding a turn about this case, as the workflow wrote it, untruncated: the deployment’s BriefingBudget applies where it is shown.

fn start_preconditions(&self) -> Vec<StartPrecondition>

What must be true of another case before this workflow may be started.

fn start_behaviour(&self) -> StartBehaviour

What starting this workflow means when a case of it is already open.

fn confirmation_subject( &self, case_ref: CaseRef, state: Option<&Value>, act: &ResolvedAct, ) -> Result<Option<ConfirmationSubject>, ErasureError>

What a confirmation the policy engine raises is about.

fn artifacts( &self, view: &ErasedWorkflowView, ) -> Result<Vec<ArtifactRef>, ErasureError>

The documents the case view describes has.

fn may_open_beside( &self, open: &[ErasedWorkflowView], ) -> Result<(), ErasedCallError>

Whether a new case may be opened while open ones are.

fn narration_briefing( &self, stage: WritingStage, view: &ErasedWorkflowView, ) -> Result<Option<String>, ErasureError>

What this workflow wants said in the phase view is in.

fn enumerations( &self, case_ref: CaseRef, state: Option<&Value>, ) -> Result<Vec<DomainEnumeration>, ErasureError>

The complete value sets this workflow accepts, for the case in state.

fn next_steps( &self, view: &ErasedWorkflowView, ) -> Result<Vec<LocalizedText>, ErasureError>

What the user may do next once the case owes nothing, erased. See WorkflowDefinition::next_steps.

fn obligation_sentence( &self, obligation: &Value, ) -> Result<Option<LocalizedText>, ErasureError>

One obligation in words, erased. See WorkflowDefinition::obligation_sentence.

fn compile_act( &self, case_ref: CaseRef, state: Option<&Value>, act: &ResolvedAct, ) -> Result<Vec<Value>, ErasedCallError>

Compiles a resolved act into erased commands.

fn nothing_changed( &self, state: Option<&Value>, act: &ResolvedAct, ) -> Option<LocalizedText>

Why an act that compiled nothing changed nothing.

fn command_policy( &self, state: Option<&Value>, command: &Value, ) -> Result<CommandPolicy, ErasureError>

Policy of an erased command.

fn validate_command( &self, state: Option<&Value>, command: &Value, ) -> Result<(), ErasedCallError>

Validates an erased command.

fn receipts( &self, events: &[ReceiptEvent<Value>], locale: &Locale, ) -> Result<Vec<OperationalReceipt>, ErasureError>

Renders receipts from erased ledger events.

fn build_interaction( &self, case_ref: CaseRef, state: Option<&Value>, requirement: &InteractionRequirement, ) -> Result<InteractionSpec, ErasedCallError>

Builds the interaction spec for a requirement of the projected view.