Struct Network 

pub struct Network {
    recv: NetworkReceiver,
    ctrl: NetworkController,
}

Fields

recv: NetworkReceiver

ctrl: NetworkController

Implementations

impl Network

pub async fn create(conf: Config) -> Result<Self, NetworkError>

pub fn controller(&mut self) -> &mut NetworkController

pub fn receiver(&mut self) -> &mut NetworkReceiver

pub fn split(&self) -> (&NetworkController, &NetworkReceiver)

pub fn split_mut(&mut self) -> (&mut NetworkController, &mut NetworkReceiver)

pub fn split_into(self) -> (NetworkController, NetworkReceiver)

pub async fn receive(&mut self) -> Option<(PublicKey, Bytes)>

Methods from Deref<Target = NetworkController>

pub fn config(&self) -> &Config

pub fn parties(&self) -> impl Iterator<Item = (&PublicKey, &Role)>

Iterate over all parties.

pub fn unicast( &mut self, s: Slot, to: PublicKey, msg: Vec<u8>, ) -> Result<(), NetworkError>

Send a message to a party, identified by the given public key.

pub fn broadcast(&mut self, s: Slot, msg: Vec<u8>) -> Result<(), NetworkError>

Send a message to all parties.

pub fn multicast<P>( &mut self, s: Slot, to: P, msg: Vec<u8>, ) -> Result<(), NetworkError>

where P: IntoIterator<Item = PublicKey>,

Send a message to several parties, identified by their public keys.

pub fn send(&mut self, cmd: SendCommand) -> Result<(), NetworkError>

General send operation, supporting custom retry policies.

pub fn add_peers<P>(&mut self, r: Role, peers: P) -> Result<(), NetworkError>

where P: IntoIterator<Item = (PublicKey, NetAddr)>,

Add the given peers to the network.

pub fn remove_peers<P>(&mut self, peers: P) -> Result<(), NetworkError>

where P: IntoIterator<Item = PublicKey>,

Remove the given peers from the network.

pub fn assign_peers<P>(&mut self, r: Role, peers: P) -> Result<(), NetworkError>

where P: IntoIterator<Item = PublicKey>,

Assign the given role to the given peers.

pub fn gc(&mut self, s: Slot) -> Result<(), NetworkError>

pub fn shutdown( &mut self, ) -> Result<impl Future<Output = ()> + use<>, NetworkError>

Trigger network shutdown.

The returned future will resolve once the server task finished.

fn length_check(&self, msg: &[u8]) -> Result<(), NetworkError>

Check the number of message bytes does not exceed the configured maximum.

fn lt_lower_bound(&self, s: Slot) -> bool

Check if the given slot is less than our lower bound.

Trait Implementations

impl Debug for Network

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

Formats the value using the given formatter.

impl Deref for Network

type Target = NetworkController

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for Network

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.