Enum TopologyChange 

pub enum TopologyChange {
    Service {
        subject: String,
        present: bool,
    },
    Channel {
        name: String,
        life: LineLife,
        state: LineState,
    },
    ConnectionOpened {
        id: u64,
        mount: Mount,
        participant: Option<String>,
    },
    ConnectionClosed {
        id: u64,
    },
    Worker {
        connection: u64,
        identity: String,
        subjects: Vec<String>,
        activities: Vec<StationActivity>,
    },
    Flow {
        connection: u64,
        line: String,
        role: FlowRole,
        present: bool,
    },
    Link {
        link_id: String,
        peer: String,
        carrier: Option<Carrier>,
        state: LinkState,
        reason: Option<String>,
        counters: LinkCounters,
    },
    Peer {
        name: String,
        present: bool,
    },
}

One change to the topology, emitted where it happens.

Variants

Service

A responder (a service) was registered or removed.

Fields

subject: String

Its subject.

present: bool

Whether it is registered now.

Channel

A channel joined the roster or changed state.

Fields

name: String

The channel.

life: LineLife

How long it keeps messages.

state: LineState

Whether it admits.

ConnectionOpened

A connection opened.

Fields

id: u64

The connection id (the supervisor pid).

mount: Mount

The transport it arrived on.

participant: Option<String>

The participant its pass names, when it has one.

ConnectionClosed

A connection closed.

Fields

id: u64

The connection id.

Worker

A connection registered as a worker: its identity is a station while the connection is open, carrying what it serves (SRV-027 R3).

Fields

connection: u64

The connection id.

identity: String

The worker’s identity, its station id.

subjects: Vec<String>

The subjects it serves: its registration’s task queue.

activities: Vec<StationActivity>

Its activities with their schema strings, as registered.

Flow

A connection began (present) or stopped using a line one way.

Fields

connection: u64

The connection id.

line: String

The line.

role: FlowRole

Which way it uses the line.

present: bool

Whether it does so now.

Link

A federated link opened, ended, or changed its observations.

Fields

link_id: String

The canonical local-device and peer link id.

peer: String

The peer device id.

carrier: Option<Carrier>

The transport and relay, when observed.

state: LinkState

Whether the link is up or down.

reason: Option<String>

The end cause, when observed.

counters: LinkCounters

Counts supplied by their source.

Peer

A cluster peer joined or left.

Fields

name: String

The peer’s node name.

present: bool

Whether it is a member now.

Trait Implementations

impl Clone for TopologyChange

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 TopologyChange

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

Formats the value using the given formatter.

impl Eq for TopologyChange

impl PartialEq for TopologyChange

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for TopologyChange