Enum EngineState 

pub enum EngineState {
    Created,
    Connecting,
    Running,
    ShuttingDown,
    Stopped,
    Failed,
}

State of the replication engine.

See module docs for the state transition diagram.

Variants

Created

Engine created but not started.

Call start() to begin replication.

Connecting

Connecting to peers.

The engine is establishing connections to configured peers. Transitions to Running when ready, or Failed if connection fails.

Running

Running and replicating.

Hot path is tailing CDC streams from peers. Cold path is periodically comparing Merkle roots.

ShuttingDown

Shutting down gracefully.

In-flight batches are being drained and cursors persisted. Transitions to Stopped when complete.

Stopped

Stopped.

Engine has shut down cleanly. Safe to drop or restart.

Failed

Failed to start or unrecoverable error.

Check logs for error details. Engine cannot recover from this state.

Trait Implementations

impl Clone for EngineState

fn clone(&self) -> EngineState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EngineState

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

Formats the value using the given formatter.

impl Display for EngineState

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

Formats the value using the given formatter.

impl PartialEq for EngineState

fn eq(&self, other: &EngineState) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for EngineState

impl Eq for EngineState

impl StructuralPartialEq for EngineState