Enum RuntimeCommand 

pub enum RuntimeCommand {
    RegisterRoute {
        spec: CanonicalRouteSpec,
        command_id: String,
        causation_id: Option<String>,
    },
    StartRoute {
        route_id: String,
        command_id: String,
        causation_id: Option<String>,
    },
    StopRoute {
        route_id: String,
        command_id: String,
        causation_id: Option<String>,
    },
    SuspendRoute {
        route_id: String,
        command_id: String,
        causation_id: Option<String>,
    },
    ResumeRoute {
        route_id: String,
        command_id: String,
        causation_id: Option<String>,
    },
    ReloadRoute {
        route_id: String,
        command_id: String,
        causation_id: Option<String>,
    },
    FailRoute {
        route_id: String,
        error: String,
        command_id: String,
        causation_id: Option<String>,
    },
    RemoveRoute {
        route_id: String,
        command_id: String,
        causation_id: Option<String>,
    },
}

Variants

RegisterRoute

Fields

spec: CanonicalRouteSpec

command_id: String

causation_id: Option<String>

StartRoute

Fields

route_id: String

command_id: String

causation_id: Option<String>

StopRoute

Fields

route_id: String

command_id: String

causation_id: Option<String>

SuspendRoute

Fields

route_id: String

command_id: String

causation_id: Option<String>

ResumeRoute

Fields

route_id: String

command_id: String

causation_id: Option<String>

ReloadRoute

Fields

route_id: String

command_id: String

causation_id: Option<String>

FailRoute

Internal lifecycle command emitted by runtime adapters when a route crashes at runtime.

This keeps aggregate/projection state aligned with controller-observed failures.

Fields

route_id: String

error: String

command_id: String

causation_id: Option<String>

RemoveRoute

Fields

route_id: String

command_id: String

causation_id: Option<String>

Implementations

impl RuntimeCommand

pub fn command_id(&self) -> &str

pub fn causation_id(&self) -> Option<&str>

Trait Implementations

impl Clone for RuntimeCommand

fn clone(&self) -> RuntimeCommand

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RuntimeCommand

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

Formats the value using the given formatter.

impl PartialEq for RuntimeCommand

fn eq(&self, other: &RuntimeCommand) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for RuntimeCommand

impl StructuralPartialEq for RuntimeCommand