Enum MediatorPdu 

#[non_exhaustive]
pub enum MediatorPdu {
    TopicAnnounce {
        from: String,
        topics: Vec<String>,
    },
    Forward {
        topic: String,
        msg_blob: Vec<u8>,
        type_id: String,
    },
}

Wire shape of a cross-node mediator exchange.

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.

TopicAnnounce

Announce the set of topics this node has at least one subscriber for.

Fields

from: String

topics: Vec<String>

Forward

Forward msg_blob (already serialized) to every local subscriber of topic on the receiving node.

Fields

topic: String

msg_blob: Vec<u8>

type_id: String

Trait Implementations

impl Clone for MediatorPdu

fn clone(&self) -> MediatorPdu

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MediatorPdu

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

Formats the value using the given formatter.