Struct StateReplicationManager 

pub struct StateReplicationManager { /* private fields */ }

Replicates stream state across nodes using a gossip protocol.

Each node periodically gossips its state digest to a random subset of peers; peers that detect a divergence request the full state payload.

Implementations

impl StateReplicationManager

pub fn new(node_id: impl Into<String>, config: ReplicationConfig) -> Self

Creates a new replication manager for the given node.

pub fn add_peer(&self, node_id: impl Into<String>)

Registers a peer node for gossip.

pub fn update_local_state(&self, state: Vec<u8>)

Updates the local state, recomputing the digest.

pub fn produce_gossip(&self) -> Vec<GossipMessage>

Produces gossip messages for the current round (up to fanout peers).

Returns the list of gossip messages to send.

pub fn receive_gossip(&self, msg: GossipMessage) -> StateResult<bool>

Receives and processes an incoming gossip message.

Returns true if a state synchronisation was triggered (digest differed).

pub fn local_digest(&self) -> String

Returns the current local state digest.

pub fn stats(&self) -> ReplicationStats

Returns replication statistics.

pub fn stale_peers(&self) -> Vec<String>

Returns IDs of stale peers (not heard from in stale_rounds rounds).