Struct FollowerSyncClient 

pub struct FollowerSyncClient { /* private fields */ }

Pushes leader events to a follower over transport.

Implementations

impl FollowerSyncClient

pub fn new(transport: HttpSyncTransport) -> Self

Creates a follower client with bounded in-memory buffering and default retries.

pub fn with_retry_policy(self, retry_policy: SyncRetryPolicy) -> Self

Replaces retry, backoff, and queue limits.

pub fn retry_policy(&self) -> SyncRetryPolicy

Returns the configured retry policy.

pub fn with_outbox(self, outbox: Arc<dyn SyncOutbox>) -> Self

Replaces the pending-message outbox implementation.

pub fn with_file_outbox(self, file_path: impl Into<PathBuf>) -> SyncResult<Self>

Configures a durable file outbox at file_path.

pub fn metrics(&self) -> SyncPushMetrics

Returns a snapshot of cumulative push counters.

pub fn pending_len(&self) -> usize

Returns the pending count, or zero if the outbox cannot be read.

pub fn pending_messages(&self) -> SyncResult<Vec<SyncMessage>>

Returns a complete compatibility snapshot of pending batches.

New consumers should use Self::pending_page and Self::outbox_stats so queue growth cannot determine one allocation.

pub fn pending_page( &self, limit: usize, max_bytes: usize, ) -> SyncResult<Vec<SyncMessage>>

Returns one pending page bounded before payload clones.

pub fn outbox_stats(&self) -> SyncResult<SyncOutboxStats>

Returns payload-free outbox observations.

pub fn cancel(&self)

Cancels active transport I/O and retry waits.

pub fn is_cancelled(&self) -> bool

Reports whether this client has been cancelled.

pub fn flush_pending(&self) -> SyncResult<()>

Attempts delivery of all currently queued batches.

pub fn flush_pending_with_progress(&self) -> SyncResult<Option<SyncMessage>>

Attempts queued delivery and returns the last batch durably acknowledged.

pub fn push_events(&self, message: &SyncMessage) -> SyncResult<()>

Enqueues a batch durably before attempting ordered delivery.

Trait Implementations

impl Clone for FollowerSyncClient

fn clone(&self) -> FollowerSyncClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FollowerSyncClient

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

Formats the value using the given formatter.