Enum Proposal 

#[repr(u8)]
pub enum Proposal {
    DelegateMessage(DelegateMessage),
    SetState(SetState),
    LoadTopic(LoadTopic),
    UnloadTopic(UnloadTopic),
    EpOnline(EndpointOnline),
    EpOffline(EndpointOffline),
    EpInterest(EndpointInterest),
    AckFinished(AckFinished),
}

Variants

DelegateMessage(DelegateMessage)

Hold Message: edge node ask cluster node to hold a message.

SetState(SetState)

Set State: set ack state

LoadTopic(LoadTopic)

Load Queue: load messages into the topic queue.

UnloadTopic(UnloadTopic)

EpOnline(EndpointOnline)

Ep Online: report endpoint online.

EpOffline(EndpointOffline)

Ep Offline: report endpoint offline.

EpInterest(EndpointInterest)

Ep Interest: set endpoint’s interests.

AckFinished(AckFinished)

Ack Finished: ack finished.

Trait Implementations

impl Clone for Proposal

fn clone(&self) -> Proposal

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Proposal

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Proposal

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Proposal

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

where __S: Serializer,

Serialize this value into the given Serde serializer.