Struct Kadcast 

pub struct Kadcast<const N: usize> { /* private fields */ }

Implementations

impl<const N: usize> Kadcast<N>

pub fn new(conf: Config) -> Result<Self, AddrParseError>

pub fn route_internal(&self, msg: Message)

pub async fn alive_nodes(&self, amount: usize) -> Vec<SocketAddr>

pub async fn table(&self) -> Vec<SocketAddr>

pub fn conf(&self) -> &Config

Trait Implementations

impl<const N: usize> Network for Kadcast<N>

fn flood_request<'life0, 'life1, 'async_trait>( &'life0 self, msg_inv: &'life1 Inv, ttl_as_sec: Option<u64>, hops_limit: u16, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Broadcast a GetResource request.

By utilizing the randomly selected peers per bucket in Kadcast, this broadcast does follow the so-called “Flood with Random Walk” blind search (resource discovery).

A receiver of this message is supposed to look up the resource and either return it or, if not found, rebroadcast the message to the next Kadcast bucket

• ttl_as_sec - Defines the lifespan of the request in seconds

• hops_limit - Defines maximum number of hops to receive the request

fn send_to_peer<'life0, 'async_trait>( &'life0 self, msg: Message, recv_addr: SocketAddr, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends an encoded message to a given peer.

fn send_to_alive_peers<'life0, 'async_trait>( &'life0 self, msg: Message, amount: usize, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends to random set of alive peers.

fn add_route<'life0, 'async_trait>( &'life0 mut self, topic: u8, queue: AsyncQueue<Message>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Route any message of the specified type to this queue.

fn broadcast<'life0, 'life1, 'async_trait>( &'life0 self, msg: &'life1 Message, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Broadcasts a fire-and-forget message.

fn add_filter<'life0, 'async_trait>( &'life0 mut self, msg_type: u8, filter_fn: BoxedFilter, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Moves a filter of a specified topic to Network.

fn get_info(&self) -> Result<String>

Retrieves information about the network.

fn public_addr(&self) -> &SocketAddr

Returns public address in Kadcast

fn alive_nodes_count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves number of alive nodes

fn wait_for_alive_nodes<'life0, 'async_trait>( &'life0 self, amount: usize, timeout: Duration, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,