Struct ReplicationEngine 

pub struct ReplicationEngine { /* private fields */ }

The replication engine manages all replication background tasks and state.

Implementations

impl ReplicationEngine

pub async fn new( config: ReplicationConfig, p2p_node: Arc<P2PNode>, storage: Arc<LmdbStorage>, payment_verifier: Arc<PaymentVerifier>, root_dir: &Path, fresh_write_rx: UnboundedReceiver<FreshWriteEvent>, shutdown: CancellationToken, ) -> Result<Self>

Create a new replication engine.

Errors

Returns an error if the PaidList LMDB environment cannot be opened or if the configuration fails validation.

pub fn paid_list(&self) -> &Arc<PaidList>

Get a reference to the PaidList.

pub fn start(&mut self, dht_events: Receiver<DhtNetworkEvent>)

Start all background tasks.

dht_events must be subscribed before P2PNode::start() so that the BootstrapComplete event emitted during DHT bootstrap is not missed by the bootstrap-sync gate.

pub async fn is_bootstrapping(&self) -> bool

Returns true if the node is still in the replication bootstrap phase.

During bootstrap, audit challenges return Bootstrapping instead of digests, and neighbor sync responses carry bootstrapping: true.

pub async fn wait_for_bootstrap_complete(&self, timeout: Duration) -> bool

Wait until the replication bootstrap phase completes.

Returns immediately if bootstrap has already completed. Useful for readiness probes, health checks, and test harnesses that need the node to be fully operational before proceeding.

Returns true if bootstrap completed within the timeout, false if the timeout elapsed first.

pub async fn shutdown(&mut self)

Cancel all background tasks and wait for them to terminate.

This must be awaited before dropping the engine when the caller needs the Arc<LmdbStorage> references held by background tasks to be released (e.g. before reopening the same LMDB environment).

pub fn trigger_neighbor_sync(&self)

Trigger an early neighbor sync round.

Useful after topology changes (new nodes joining, network heal after partition) when the caller wants replication to converge faster than the regular 10-20 minute cadence.

pub async fn replicate_fresh( &self, key: &XorName, data: &[u8], proof_of_payment: &[u8], )

Execute fresh replication for a newly stored record.