Enum SourceReadLifecycleState 

pub enum SourceReadLifecycleState {
    Enqueued,
    WorkerStarted {
        queue_wait_ns: u64,
    },
    ReadFinished {
        read_duration_ns: u64,
    },
    ReadFailed {
        error_code: String,
        read_duration_ns: u64,
    },
    ConsumerJoinStarted,
    ConsumerJoinFinished {
        join_duration_ns: u64,
    },
    Cancelled,
    Panicked,
}

Source-read scheduler lifecycle state.

Variants

Enqueued

A source-read job entered the scheduler.

WorkerStarted

The source worker began after the recorded queue wait.

Fields

queue_wait_ns: u64

Nanoseconds from source job enqueue to worker start.

ReadFinished

The source worker completed the read.

Fields

read_duration_ns: u64

Nanoseconds spent executing the source read.

ReadFailed

A classified error ended the source read.

Fields

error_code: String

Stable machine code of the source-read error.

read_duration_ns: u64

Nanoseconds from read start to its error.

ConsumerJoinStarted

The consumer began waiting for the source worker result.

ConsumerJoinFinished

The consumer finished joining the source worker result.

Fields

join_duration_ns: u64

Nanoseconds spent waiting for the source worker result.

Cancelled

Cooperative cancellation ended the source read.

Panicked

An unwind ended the source read.

Trait Implementations

impl Clone for SourceReadLifecycleState

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SourceReadLifecycleState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SourceReadLifecycleState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for SourceReadLifecycleState

impl PartialEq for SourceReadLifecycleState

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for SourceReadLifecycleState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for SourceReadLifecycleState