Struct Gossip 

pub struct Gossip<N, const MTU: usize = 256, const OUT: usize = 2048> { /* private fields */ }

Epidemic gossip flood over a 4-connected torus mesh.

Implements NetworkWrite (wrap + flood) and NetworkRead (receive, dedup, forward, deliver).

Implementations

impl<N, const MTU: usize, const OUT: usize> Gossip<N, MTU, OUT>

where N: Datalink,

pub fn address(&self) -> Address

Returns this node’s own address.

pub fn builder() -> GossipBuilder<N, MTU, OUT>

Creates a new gossip node with directional links.

Trait Implementations

impl<N, const MTU: usize, const OUT: usize> NetworkRead for Gossip<N, MTU, OUT>

where N: Datalink,

type Error = GossipError<<N as Datalink>::ReadError>

Error type for read operations.

async fn read(&mut self, buffer: &mut [u8]) -> Result<usize, Self::Error>

Reads a packet into the provided buffer, returning its length.

impl<N, const MTU: usize, const OUT: usize> NetworkWrite for Gossip<N, MTU, OUT>

where N: Datalink,

type Error = GossipError<<N as Datalink>::WriteError>

Error type for write operations.

async fn write(&mut self, data: &[u8]) -> Result<(), Self::Error>

Writes a packet to the network.