Struct Provenance 

pub struct Provenance {
    pub stages: Vec<StageProvenance>,
    pub view_provenance: ViewProvenance,
    pub frame_receive_ts: MonotonicTs,
    pub pipeline_complete_ts: MonotonicTs,
    pub total_latency: Duration,
    pub frame_age: Option<Duration>,
    pub queue_hold_time: Duration,
    pub frame_included: bool,
}

Full provenance for one processed frame.

Every output carries this, making production debugging tractable.

Timing semantics

All timestamps are MonotonicTs values — they share the same monotonic clock domain as FrameEnvelope::ts().

• frame_receive_ts — when the frame was dequeued from the bounded queue.
• pipeline_complete_ts — when all stages finished and output was constructed.
• Per-stage start_ts / end_ts — real wall-clock offsets converted to monotonic nanoseconds from the pipeline epoch for ordering consistency.

Fields

stages: Vec<StageProvenance>

Per-stage provenance records, in execution order.

view_provenance: ViewProvenance

View-system provenance for this frame.

frame_receive_ts: MonotonicTs

Timestamp when the frame was dequeued from the bounded queue (start of pipeline processing for this frame).

pipeline_complete_ts: MonotonicTs

Timestamp when the pipeline completed processing this frame.

total_latency: Duration

Total pipeline latency (receive → complete).

frame_age: Option<Duration>

Wall-clock age of the frame at processing time.

Computed as WallTs::now() - frame.wall_ts() when the frame enters pipeline processing. A large value indicates the frame was stale before the executor even touched it — typically due to buffer-pool starvation, TCP backlog, or slow decode.

None if wall-clock age could not be determined (e.g., if the frame’s wall timestamp is in the future due to clock skew).

queue_hold_time: Duration

Time the frame spent waiting in the bounded queue.

Measured from push() to pop() using Instant. A consistently low value combined with high frame_age proves that staleness originates upstream of the queue (e.g., in the decoder or TCP receive buffer), not from queue backlog.

frame_included: bool

Whether this output includes the source frame.

Always true for FrameInclusion::Always, always false for FrameInclusion::Never, and periodic for FrameInclusion::Sampled.

Trait Implementations

impl Clone for Provenance

fn clone(&self) -> Provenance

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Provenance

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

Formats the value using the given formatter.