Enum RuntimeObservationPayload 

pub enum RuntimeObservationPayload {
    QueryBoundary {
        boundary: QueryBoundaryKind,
    },
    PlanExecutionBoundary {
        boundary: PlanExecutionBoundaryKind,
    },
    TaskLifecycle(Box<RuntimeTaskLifecycleObservation>),
    Admission(Box<RuntimeAdmissionObservation>),
    GpuJob(Box<RuntimeGpuJobObservation>),
    StreamLease(Box<RuntimeStreamLeaseObservation>),
    SourceRead(Box<RuntimeSourceReadObservation>),
    ResourceMeasurement(Box<RuntimeResourceMeasurementObservation>),
    Reservation(Box<RuntimeReservationObservation>),
    CleanupFailure(Box<RuntimeCleanupFailureObservation>),
    OperatorStage(Box<RuntimeOperatorStageObservation>),
}

Typed dynamic event payload.

Variants

QueryBoundary

Query lifecycle boundary stored with the event timestamp.

Fields

boundary: QueryBoundaryKind

Query lifecycle transition represented by this event.

PlanExecutionBoundary

Native plan invocation boundary stored with the event timestamp.

Fields

boundary: PlanExecutionBoundaryKind

Native plan invocation transition represented by this event.

TaskLifecycle(Box<RuntimeTaskLifecycleObservation>)

Compiled task attempt lifecycle evidence.

Admission(Box<RuntimeAdmissionObservation>)

Admission lifecycle and immutable grant evidence.

GpuJob(Box<RuntimeGpuJobObservation>)

GPU executor job lifecycle evidence.

StreamLease(Box<RuntimeStreamLeaseObservation>)

Stream acquisition and release lifecycle evidence.

SourceRead(Box<RuntimeSourceReadObservation>)

Source worker and consumer-join lifecycle evidence.

ResourceMeasurement(Box<RuntimeResourceMeasurementObservation>)

Resource sample with its owning scope and provenance.

Reservation(Box<RuntimeReservationObservation>)

Reservation ownership transition and byte charge evidence.

CleanupFailure(Box<RuntimeCleanupFailureObservation>)

Secondary cleanup failure retained without replacing a primary query error.

OperatorStage(Box<RuntimeOperatorStageObservation>)

Operator-substage lifecycle for blocking native primitives.

Trait Implementations

impl Clone for RuntimeObservationPayload

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 RuntimeObservationPayload

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RuntimeObservationPayload

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for RuntimeObservationPayload

impl PartialEq for RuntimeObservationPayload

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for RuntimeObservationPayload

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 RuntimeObservationPayload