Enum RuntimeCommand 

#[non_exhaustive]
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>,
        stop_budget: Option<Duration>,
    },
    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>,
    },
    ReloadTlsCerts {
        scheme: String,
        host: String,
        port: u16,
        command_id: String,
        causation_id: Option<String>,
    },
    ReloadTemplates {
        route_id: String,
        command_id: String,
        causation_id: Option<String>,
    },
}

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future 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>

stop_budget: Option<Duration>

Effective graceful stop budget. None preserves the legacy default shutdown bound (the route registry’s DEFAULT_SHUTDOWN_TIMEOUT); Some(budget) bounds the stop with the given budget. Future graceful-shutdown producers (CLI, supervisor, orchestrators) MUST send Some(budget) explicitly — None is reserved for the registry/reload semantics (legacy default bound), not a default for graceful stops.

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>

ReloadTlsCerts

Fields

scheme: String

host: String

port: u16

command_id: String

causation_id: Option<String>

ReloadTemplates

Reload template sources for a route (infrastructure command).

Intercepted in RuntimeBus::execute BEFORE journal recovery + dedup, exactly like ReloadTlsCerts: it is idempotent, NOT journaled, and does not mutate RouteStatus. Dispatches to TemplateReloadRegistry::reload_route.

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) -> Self

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 Eq for RuntimeCommand

impl PartialEq for RuntimeCommand

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for RuntimeCommand