Struct MessageRelay 

pub struct MessageRelay {
    pub path: Vec<Did>,
    pub next_hop: Did,
    pub destination: Did,
}

MessageRelay guide message passing on rings network by relay.

All messages should be sent with MessageRelay. By calling relay method in correct place, MessageRelay help to do things:

• Record the whole transport path for inspection.
• Get the sender of a message.

Fields

path: Vec<Did>

A push only stack. Record routes when handling messages.

next_hop: Did

The next node to handle the message. A message handler will pick transport by this field.

destination: Did

The destination of the message. It may help the handler to find out next_hop in some situations.

Implementations

impl MessageRelay

pub fn new(path: Vec<Did>, next_hop: Did, destination: Did) -> MessageRelay

Create a new MessageRelay.

pub fn forward( &self, current: Did, next_hop: Did, ) -> Result<MessageRelay, Error>

Validate relay, then create a new MessageRelay that have current did in the end of path. The new relay will use next_hop as next_hop and self.destination as destination.

pub fn path_report(&self, current: Did) -> Result<MessageRelay, Error>

Validate relay, then create a new MessageRelay that used to report the message. The new relay will use self.path[self.path.len() - 1] as next_hop and self.sender() as destination. In the new relay, the path will be cleared and only have current did.

pub fn routed_report( &self, current: Did, destination: Did, next_hop: Did, ) -> Result<MessageRelay, Error>

Validate relay, then create a fresh Chord-routed report relay.

The caller must infer next_hop from the destination before invoking this constructor.

pub fn report( &self, current: Did, policy: ReportReturnPolicy, routed_next_hop: Option<Did>, ) -> Result<MessageRelay, Error>

Create a report relay with an explicit return policy.

pub fn reset_destination(&self, destination: Did) -> MessageRelay

Sometime the sender may not know the destination of the message. They just use next_hop as destination. The next node can find a new next_hop, and may use this function to set that next_hop as destination again.

pub fn validate(&self, current: Did) -> Result<(), Error>

Check if path and destination is valid.

pub fn sender(&self) -> Did

👎Deprecated:

please use origin_sender instead

Get the origin sender of current message. Should be the first element of path.

pub fn try_origin_sender(&self) -> Result<Did, Error>

Get the origin sender of current message as a checked relay-path boundary.

pub fn origin_sender(&self) -> Did

Get the origin sender of current message.

The origin should be the first element of path. Empty relay paths keep the legacy fallback to destination; callers that must distinguish an invalid relay boundary from a real origin should use try_origin_sender.

Trait Implementations

impl Clone for MessageRelay

fn clone(&self) -> MessageRelay

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageRelay

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MessageRelay

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for MessageRelay

impl PartialEq for MessageRelay

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for MessageRelay

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.

impl StructuralPartialEq for MessageRelay