Skip to main content

PayloadSender

rings_node::prelude

Trait PayloadSender 

Source 
pub trait PayloadSender {

Show 13 methods    // Required methods
    fn session_sk(&self) -> &SessionSk;
    fn dht(&self) -> Arc<PeerRing> ⓘ;
    fn is_connected(&self, did: Did) -> bool;
    fn do_send_payload<'life0, 'async_trait>(
        &'life0 self,
        did: Did,
        payload: MessagePayload,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             Self: 'async_trait;

    // Provided methods
    fn infer_next_hop(
        &self,
        destination: Did,
        next_hop: Option<Did>,
    ) -> Result<Did, Error> { ... }
    fn send_payload<'life0, 'async_trait>(
        &'life0 self,
        payload: MessagePayload,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             Self: Sync + 'async_trait { ... }
    fn send_message_by_hop<'life0, 'async_trait, T>(
        &'life0 self,
        msg: T,
        destination: Did,
        next_hop: Did,
    ) -> Pin<Box<dyn Future<Output = Result<Uuid, Error>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             T: Serialize + Send + 'async_trait,
             Self: Sync + 'async_trait { ... }
    fn send_message<'life0, 'async_trait, T>(
        &'life0 self,
        msg: T,
        destination: Did,
    ) -> Pin<Box<dyn Future<Output = Result<Uuid, Error>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             T: Serialize + Send + 'async_trait,
             Self: Sync + 'async_trait { ... }
    fn send_direct_message<'life0, 'async_trait, T>(
        &'life0 self,
        msg: T,
        destination: Did,
    ) -> Pin<Box<dyn Future<Output = Result<Uuid, Error>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             T: Serialize + Send + 'async_trait,
             Self: Sync + 'async_trait { ... }
    fn send_report_message<'life0, 'life1, 'async_trait, T>(
        &'life0 self,
        payload: &'life1 MessagePayload,
        msg: T,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             'life1: 'async_trait,
             T: Serialize + Send + 'async_trait,
             Self: Sync + 'async_trait { ... }
    fn forward_by_relay<'life0, 'life1, 'async_trait>(
        &'life0 self,
        payload: &'life1 MessagePayload,
        relay: MessageRelay,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             'life1: 'async_trait,
             Self: Sync + 'async_trait { ... }
    fn forward_payload<'life0, 'life1, 'async_trait>(
        &'life0 self,
        payload: &'life1 MessagePayload,
        next_hop: Option<Did>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             'life1: 'async_trait,
             Self: Sync + 'async_trait { ... }
    fn reset_destination<'life0, 'life1, 'async_trait>(
        &'life0 self,
        payload: &'life1 MessagePayload,
        next_hop: Did,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             'life1: 'async_trait,
             Self: Sync + 'async_trait { ... }

}
Expand description

Trait of PayloadSender

Required Methods§

Source

fn session_sk(&self) -> &SessionSk

Get the session sk

Source

fn dht(&self) -> Arc<PeerRing> ⓘ

Get access to DHT.

Source

fn is_connected(&self, did: Did) -> bool

Used to check if destination is already connected when infer_next_hop

Source

fn do_send_payload<'life0, 'async_trait>( &'life0 self, did: Did, payload: MessagePayload, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

Send a message payload to a specified DID.

Provided Methods§

Source

fn infer_next_hop( &self, destination: Did, next_hop: Option<Did>, ) -> Result<Did, Error>

Infer the next hop for a message by calling dht.find_successor().

Source

fn send_payload<'life0, 'async_trait>( &'life0 self, payload: MessagePayload, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: Sync + 'async_trait,

Alias for do_send_payload that sets the next hop to payload.relay.next_hop.

Source

fn send_message_by_hop<'life0, 'async_trait, T>( &'life0 self, msg: T, destination: Did, next_hop: Did, ) -> Pin<Box<dyn Future<Output = Result<Uuid, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, T: Serialize + Send + 'async_trait, Self: Sync + 'async_trait,

Send a message to a specified destination by specified next hop.

Source

fn send_message<'life0, 'async_trait, T>( &'life0 self, msg: T, destination: Did, ) -> Pin<Box<dyn Future<Output = Result<Uuid, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, T: Serialize + Send + 'async_trait, Self: Sync + 'async_trait,

Send a message to a specified destination.

Source

fn send_direct_message<'life0, 'async_trait, T>( &'life0 self, msg: T, destination: Did, ) -> Pin<Box<dyn Future<Output = Result<Uuid, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, T: Serialize + Send + 'async_trait, Self: Sync + 'async_trait,

Send a direct message to a specified destination.

Source

fn send_report_message<'life0, 'life1, 'async_trait, T>( &'life0 self, payload: &'life1 MessagePayload, msg: T, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, T: Serialize + Send + 'async_trait, Self: Sync + 'async_trait,

Send a report message to a specified destination.

Source

fn forward_by_relay<'life0, 'life1, 'async_trait>( &'life0 self, payload: &'life1 MessagePayload, relay: MessageRelay, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, Self: Sync + 'async_trait,

Forward a payload message by relay. It just create a new payload, cloned data, resigned with session and send

Source

fn forward_payload<'life0, 'life1, 'async_trait>( &'life0 self, payload: &'life1 MessagePayload, next_hop: Option<Did>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, Self: Sync + 'async_trait,

Forward a payload message, with the next hop inferred by the DHT.

Source

fn reset_destination<'life0, 'life1, 'async_trait>( &'life0 self, payload: &'life1 MessagePayload, next_hop: Did, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, Self: Sync + 'async_trait,

Reset the destination to a secp DID.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§