Struct SyncForwarder 

pub struct SyncForwarder { /* private fields */ }

Sync message forwarder for multi-hop mesh networks

The forwarder tracks which batches have been forwarded to prevent loops and determines the appropriate forwarding targets based on sync direction.

Implementations

impl SyncForwarder

pub fn new(local_node_id: PublicKey) -> SyncForwarder

Create a new forwarder

pub fn set_parent(&self, parent_id: Option<PublicKey>)

Set the parent node for upward forwarding

pub fn add_child(&self, child_id: PublicKey)

Add a child node for downward forwarding

pub fn remove_child(&self, child_id: &PublicKey)

Remove a child node

pub fn parent_id(&self) -> Option<PublicKey>

Get the parent node ID

pub fn children(&self) -> Vec<PublicKey>

Get child node IDs

pub fn was_forwarded(&self, batch_id: u64) -> bool

Check if a batch has already been forwarded

pub fn mark_forwarded(&self, batch_id: u64)

Mark a batch as forwarded (for deduplication)

pub fn forward_targets( &self, batch: &SyncBatch, source_peer: PublicKey, connected_peers: &[PublicKey], ) -> Option<Vec<PublicKey>>

Determine forwarding targets for a received batch

Returns None if:

• Batch was already forwarded (duplicate)
• Batch TTL is 0 (expired)

Returns Some(empty vec) if no forwarding needed. Returns Some(targets) with the peers to forward to.

pub fn prepare_for_forward(&self, batch: &SyncBatch) -> Option<SyncBatch>

Prepare a batch for forwarding by decrementing TTL

Returns a cloned batch with decremented TTL, or None if TTL would be 0.