pub struct NetzengpassWorkflow;Expand description
Netzengpassinformation workflow — NetworkConstraintDocument.
ÜNB ↔ VNB. Receiver acknowledges within 6h (BK6-20-059 §4.3).
Implementations§
Source§impl NetzengpassWorkflow
impl NetzengpassWorkflow
Sourcepub fn event_prefix() -> &'static str
pub fn event_prefix() -> &'static str
Return the event-type prefix for this workflow’s events.
Trait Implementations§
Source§impl Workflow for NetzengpassWorkflow
impl Workflow for NetzengpassWorkflow
Source§type State = AckForwardState
type State = AckForwardState
Domain-specific process state, reconstructed by replaying events.
Source§type Event = NetzengpassEvent
type Event = NetzengpassEvent
Domain event type emitted by this workflow.
Source§type Command = AckForwardCommand
type Command = AckForwardCommand
Command type handled by this workflow.
Source§fn on_deadline(
deadline: &Deadline,
state: &Self::State,
) -> Option<Self::Command>
fn on_deadline( deadline: &Deadline, state: &Self::State, ) -> Option<Self::Command>
Map a fired deadline to a compensating command. Read more
Source§fn apply(state: Self::State, event: &Self::Event) -> Self::State
fn apply(state: Self::State, event: &Self::Event) -> Self::State
Fold a domain event into the current state. Read more
Source§fn handle(
state: &Self::State,
command: Self::Command,
) -> Result<WorkflowOutput<Self::Event>, WorkflowError>
fn handle( state: &Self::State, command: Self::Command, ) -> Result<WorkflowOutput<Self::Event>, WorkflowError>
Source§fn state_schema_version() -> u32
fn state_schema_version() -> u32
Schema version for serialized
Workflow::State payloads. Read moreSource§fn upcast(
_event_type: &str,
_from_version: u32,
payload: Value,
) -> Result<Value, EngineError>
fn upcast( _event_type: &str, _from_version: u32, payload: Value, ) -> Result<Value, EngineError>
Upcast a stored event payload from an older schema version. Read more
Source§fn version_policy() -> WorkflowVersionPolicy
fn version_policy() -> WorkflowVersionPolicy
Declares which BDEW format versions this workflow accepts for in-flight
processes. Read more
Auto Trait Implementations§
impl Freeze for NetzengpassWorkflow
impl RefUnwindSafe for NetzengpassWorkflow
impl Send for NetzengpassWorkflow
impl Sync for NetzengpassWorkflow
impl Unpin for NetzengpassWorkflow
impl UnsafeUnpin for NetzengpassWorkflow
impl UnwindSafe for NetzengpassWorkflow
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more