Struct StatusObserver 

pub struct StatusObserver { /* private fields */ }

Updates the shared Status as the engine reports lifecycle and progress. Cheap and non-blocking, per the Observer hot-path contract.

Implementations

impl StatusObserver

pub fn new(status: Arc<Status>) -> Self

Trait Implementations

impl Debug for StatusObserver

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

Formats the value using the given formatter.

impl Observer for StatusObserver

fn on_backfill_started(&self, indexes: &[IndexName])

Backfill is starting for indexes (those the sink reported unseeded).

fn on_index_seeded(&self, index: &IndexName)

index’s backfill is complete and it has been marked seeded.

fn on_live_started(&self)

Live capture has started; the pipeline is now following ongoing changes.

fn on_change_captured(&self)

One change was pulled from the source into the queue.

fn on_batch_committed(&self, stats: BatchStats)

A batch was built, flushed, and acked. See BatchStats.

fn on_document_quarantined(&self, _index: &str, _id: &str, _reason: &str)

A document was quarantined: the sink rejected it at the item level and the engine’s failure policy is to skip and continue (see FailurePolicy::Skip). The document is not applied and the batch proceeds, so it is not redelivered — this is the signal to surface it (a metric, a log, a dead-letter record). index and id are the destination’s names for it; reason is why it was rejected.

fn on_slot_lag(&self, bytes: u64)

The source’s capture lag, in bytes behind the latest position — e.g. a replication slot’s distance from the server’s current WAL. Reported by whoever polls ChangeCapture::lag, not by the engine loop itself.

fn on_error(&self, error: &str)

The pipeline stopped on an error (rendered to a string, since the engine’s error type is not part of this neutral surface).

fn on_indexes_ensured(&self, count: usize)

The target indexes have been ensured at the sink (count of them), before any documents flow.

fn on_backfill_completed(&self)

The backfill phase finished (all unseeded indexes seeded), or was skipped.