Struct MultiPeerCatchUp 

pub struct MultiPeerCatchUp { /* private fields */ }

Pipelined catch-up from multiple peer nodes simultaneously.

Spawns one thread per peer in peers and waits for all to finish (or for the first to succeed). Returns the name of the peer that supplied the entries, or None if no peer could serve the range.

The log_writer_factory closure is called once per thread to produce a per-thread LogWriter. The factory must be Send + Sync.

Implementations

impl MultiPeerCatchUp

pub fn new(peers: Vec<(String, SocketAddr)>, start_vlsn: u64) -> Self

Create a new multi-peer catch-up request.

peers is a list of (node_name, socket_addr) pairs to try.

pub fn run<F, W>(self, make_writer: F) -> Option<String>

where F: Fn() -> W + Send + Sync + 'static, W: LogWriter + Send + 'static,

Run pipelined catch-up.

Spawns one thread per peer and waits for the first to succeed. Each thread calls catch_up_from_peer; the winning thread’s entries are applied through make_writer(). Other threads are joined once the first succeeds.

Returns the name of the first peer that successfully served the range, or None if all peers declined.