Struct KaskadeWorkflow 

pub struct KaskadeWorkflow;

Kaskade workflow — emergency measures per § 13 Abs. 2 EnWG.

ÜNB → VNB → ANB. Receiver acknowledges within 6h (BK6-20-059 §4.3). Only active for Marktrolle::Nb and Marktrolle::Unb deployments.

Implementations

impl KaskadeWorkflow

pub fn event_prefix() -> &'static str

Return the event-type prefix for this workflow’s events.

Trait Implementations

impl Workflow for KaskadeWorkflow

type State = AckForwardState

Domain-specific process state, reconstructed by replaying events.

type Event = KaskadeEvent

Domain event type emitted by this workflow.

type Command = AckForwardCommand

Command type handled by this workflow.

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

Map a fired deadline to a compensating command.

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.