Struct ReplicationFollower 

pub struct ReplicationFollower { /* private fields */ }

A replication follower that polls a leader’s /wal/stream endpoint and applies WAL records to a local database directory via SharedWal::replay.

Usage:

use mongreldb_client::ReplicationFollower;

let mut follower = ReplicationFollower::new("http://leader:8453", "/local/copy")?;
follower.sync(); // fetches and applies all new records since last sync

Implementations

impl ReplicationFollower

pub fn new(leader_url: &str, local_path: impl AsRef<Path>) -> ClientResult<Self>

Create a follower. leader_url is the daemon base URL; local_path is the local database directory to sync into.

pub fn with_bearer_token(self, token: impl Into<String>) -> Self

pub fn with_basic_auth( self, username: impl Into<String>, password: impl Into<String>, ) -> Self

pub fn with_local_encryption_passphrase( self, passphrase: impl Into<String>, ) -> Self

pub fn with_local_credentials( self, username: impl Into<String>, password: impl Into<String>, ) -> Self

pub fn sync(&mut self) -> Result<usize, String>

Bootstrap when needed, fetch complete committed transactions, append them durably, recover the local database, then advance the watermark.

pub fn bootstrap(&mut self) -> Result<(), String>

pub fn last_epoch(&self) -> u64

The highest leader commit epoch applied so far.

pub fn last_seq(&self) -> u64

Backward-compatible alias for Self::last_epoch.

Trait Implementations

impl Debug for ReplicationFollower

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.