Enum Message 

#[non_exhaustive]
pub enum Message {
    ConnectNodeSend(ConnectNodeSend),
    ConnectNodeReport(ConnectNodeReport),
    FindSuccessorSend(FindSuccessorSend),
    FindSuccessorReport(FindSuccessorReport),
    NotifyPredecessorSend(NotifyPredecessorSend),
    NotifyPredecessorReport(NotifyPredecessorReport),
    PeerLivenessProbe(PeerLivenessProbe),
    PeerLivenessReport(PeerLivenessReport),
    SearchEntry(SearchEntry),
    FoundEntry(FoundEntry),
    OperateEntry(PlacedEntryOperation),
    SyncEntriesWithSuccessor(SyncEntriesWithSuccessor),
    SyncEntriesWithSuccessorReport(SyncEntriesWithSuccessorReport),
    CustomMessage(CustomMessage),
    E2eHandshakeRequest(E2eHandshakeRequest),
    E2eHandshakeResponse(E2eHandshakeResponse),
    E2eStreamFrame(E2eStreamFrame),
    QueryForTopoInfoSend(QueryForTopoInfoSend),
    QueryForTopoInfoReport(QueryForTopoInfoReport),
    Chunk(Chunk),
}

A collection MessageType use for unified management.

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.

ConnectNodeSend(ConnectNodeSend)

Remote message of try connecting a node.

ConnectNodeReport(ConnectNodeReport)

Response of ConnectNodeSend.

FindSuccessorSend(FindSuccessorSend)

Remote message of find successor.

FindSuccessorReport(FindSuccessorReport)

Response of FindSuccessorSend.

NotifyPredecessorSend(NotifyPredecessorSend)

Remote message of notify a predecessor.

NotifyPredecessorReport(NotifyPredecessorReport)

Response of NotifyPredecessorSend.

PeerLivenessProbe(PeerLivenessProbe)

Overlay liveness probe.

PeerLivenessReport(PeerLivenessReport)

Overlay liveness probe response.

SearchEntry(SearchEntry)

Remote message for searching an entry.

FoundEntry(FoundEntry)

Response when entries are found.

OperateEntry(PlacedEntryOperation)

Remote message for entry operations.

SyncEntriesWithSuccessor(SyncEntriesWithSuccessor)

Remote message for entry syncing.

SyncEntriesWithSuccessorReport(SyncEntriesWithSuccessorReport)

Response after synced entries are durably persisted.

CustomMessage(CustomMessage)

Custom messages.

E2eHandshakeRequest(E2eHandshakeRequest)

Request to negotiate E2E ElGamal encryption with a signed public key.

E2eHandshakeResponse(E2eHandshakeResponse)

Response accepting E2E ElGamal encryption with a signed public key.

E2eStreamFrame(E2eStreamFrame)

Direct ElGamal-encrypted E2E stream frame.

QueryForTopoInfoSend(QueryForTopoInfoSend)

Remote message of query topological info of a node.

QueryForTopoInfoReport(QueryForTopoInfoReport)

Response of QueryForTopoInfoSend.

Chunk(Chunk)

A chunk that can be deserialized to a payload.

Implementations

impl Message

pub fn custom(msg: &[u8]) -> Result<Message, Error>

Wrap a data of message into CustomMessage.

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Message

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for Message

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

Formats the value using the given formatter.

impl Serialize for Message

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

where __S: Serializer,

Serialize this value into the given Serde serializer.