Enum anachro_icd::arbitrator::Arbitrator

pub enum Arbitrator<'a> {
    Control(Control),
    PubSub(Result<PubSubResponse<'a>, PubSubError>),
    ObjStore,
    Mailbox,
}

The primary Arbitrator mesage

These are all messages that are sent FROM the Arbitrator, TO the Components/Clients

Variants

Control(Control)

Control messages

Control messages are intended to be the primary management channel between an Arbitrator and a Component/Client

PubSub(Result<PubSubResponse<'a>, PubSubError>)

Pub/Sub messages

These are messages sent on the Publish/Subscribe channel

ObjStore

Object Store messages

These are messages intended for the Object Store channel for sending bulk messages.

This functionality has not yet been implemented.

Mailbox

Mailbox messages

These are messages intended for the Mailbox layer, including guaranteed delivery messages and bulk message delivery

This functionality has not yet been implemented.

Trait Implementations

impl<'a> Debug for Arbitrator<'a>

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

Formats the value using the given formatter.

impl<'de: 'a, 'a> Deserialize<'de> for Arbitrator<'a>

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl<'a> Eq for Arbitrator<'a>

impl<'a> PartialEq<Arbitrator<'a>> for Arbitrator<'a>

fn eq(&self, other: &Arbitrator<'a>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Arbitrator<'a>) -> bool

This method tests for !=.

impl<'a> Serialize for Arbitrator<'a>

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.

impl<'a> StructuralEq for Arbitrator<'a>

impl<'a> StructuralPartialEq for Arbitrator<'a>