Struct Retry 

pub struct Retry<K> {
    inner: Arc<Inner<K>>,
}

Retry wraps a Network and returns acknowledgements to senders.

It also retries messages until either an acknowledgement has been received or client code has indicated that the messages are no longer of interest by invoking Retry::gc.

Each message that is sent has a trailer appended that contains the bucket number and ID of the message. Receivers will send this trailer back. The sender then stops retrying the corresponding message.

Note that if malicious parties modify the trailer and have it point to a different message, they can only remove themselves from the set of parties the sender is expecting an acknowledgement from.

Fields

inner: Arc<Inner<K>>

Implementations

impl<K> Retry<K>

where K: Eq + Ord + Clone + Display + Hash + Send + Sync + 'static,

pub async fn create(cfg: NetConf<K>) -> Result<Self, NetworkError>

pub async fn broadcast<B>( &self, b: B, data: Vec<u8>, ) -> Result<Id, NetworkError>

where B: Into<Bucket>,

pub async fn multicast<B>( &self, to: Vec<K>, b: B, data: Vec<u8>, ) -> Result<Id, NetworkError>

where B: Into<Bucket>,

pub async fn unicast<B>( &self, to: K, b: B, data: Vec<u8>, ) -> Result<Id, NetworkError>

where B: Into<Bucket>,

pub async fn add( &self, peers: Vec<(K, PublicKey, Address)>, ) -> Result<(), NetworkError>

pub async fn remove(&self, peers: Vec<K>) -> Result<(), NetworkError>

pub async fn assign(&self, r: Role, peers: Vec<K>) -> Result<(), NetworkError>

pub async fn receive(&self) -> Result<(K, Bytes), NetworkError>

pub fn gc<B: Into<Bucket>>(&self, bucket: B)

pub fn rm<B: Into<Bucket>>(&self, bucket: B, id: Id)

async fn send( &self, b: Bucket, to: Target<K>, data: Vec<u8>, ) -> Result<Id, NetworkError>

fn next_id(&self) -> Id

Trait Implementations

impl<K: Clone> Clone for Retry<K>

fn clone(&self) -> Retry<K>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<K: Debug> Debug for Retry<K>

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

Formats the value using the given formatter.

impl<K> Drop for Retry<K>

fn drop(&mut self)

Executes the destructor for this type.