Enum RuntimeState 

pub enum RuntimeState {
    Starting,
    Running,
    Paused,
    Draining,
    Stopped,
    Failed,
}

Observable lifecycle state of a running connector, read via ConnectorHandle::state.

Variants

Starting

Spawned but not yet inside the loop (seeking to its checkpoint).

Running

Actively polling and writing.

Paused

Parked by pause; committing nothing until resumed.

Draining

Draining the remaining available records on the way to a clean stop.

Stopped

Stopped cleanly — the source drained and both ends were closed.

Failed

Stopped because the loop returned an error.

Trait Implementations

impl Clone for RuntimeState

fn clone(&self) -> RuntimeState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for RuntimeState

impl Debug for RuntimeState

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

Formats the value using the given formatter.

impl Eq for RuntimeState

impl PartialEq for RuntimeState

fn eq(&self, other: &RuntimeState) -> 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 StructuralPartialEq for RuntimeState