Enum ReloadAction 

pub enum ReloadAction {
    Swap {
        route_id: String,
    },
    Restart {
        route_id: String,
    },
    Add {
        route_id: String,
    },
    Remove {
        route_id: String,
    },
}

Actions the coordinator can take per route.

Variants

Swap

Pipeline may have changed — atomic swap (zero-downtime).

This action is taken when the route exists and from_uri is unchanged. Even if the pipeline is identical, swapping is harmless (atomic pointer swap).

Fields

route_id: String

Restart

Consumer (from_uri) changed — must stop and restart.

Fields

route_id: String

Add

New route — add and start.

Fields

route_id: String

Remove

Route removed from config — stop and delete.

Fields

route_id: String

Trait Implementations

impl Clone for ReloadAction

fn clone(&self) -> ReloadAction

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReloadAction

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

Formats the value using the given formatter.

impl PartialEq for ReloadAction

fn eq(&self, other: &ReloadAction) -> 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 StructuralPartialEq for ReloadAction