Struct StammdatenWorkflow 

pub struct StammdatenWorkflow;

Stammdatenübermittlung workflow for Redispatch 2.0.

Handles the reception, acknowledgement, and optional forwarding of Stammdaten documents exchanged between ANB, VNB, and ÜNB.

Spawn via mako_engine::process::Process:

let process = ctx.spawn::<StammdatenWorkflow>(
    tenant_id,
    WorkflowId::new(WORKFLOW_NAME, "FV2025-10-01"),
);

Trait Implementations

impl Workflow for StammdatenWorkflow

fn on_deadline( deadline: &Deadline, state: &Self::State, ) -> Option<Self::Command>

Fire deadline commands when the ACK or forward windows expire.

type State = StammdatenState

Domain-specific process state, reconstructed by replaying events.

type Event = StammdatenEvent

Domain event type emitted by this workflow.

type Command = StammdatenCommand

Command type handled by this workflow.

fn apply(state: Self::State, event: &Self::Event) -> Self::State

Fold a domain event into the current state.

fn handle( state: &Self::State, command: Self::Command, ) -> Result<WorkflowOutput<Self::Event>, WorkflowError>

Validate command against state and return the events to emit.

fn state_schema_version() -> u32

Schema version for serialized Workflow::State payloads.

fn upcast( _event_type: &str, _from_version: u32, payload: Value, ) -> Result<Value, EngineError>

Upcast a stored event payload from an older schema version.

fn version_policy() -> WorkflowVersionPolicy

Declares which BDEW format versions this workflow accepts for in-flight processes.