Struct GraphMeasuredPeakRow 

pub struct GraphMeasuredPeakRow {
    pub query_id: Option<QueryId>,
    pub node_id: String,
    pub node_index: usize,
    pub algorithm: GraphAlgorithm,
    pub execution_state: GraphClaimExecutionState,
    pub measured_peak_bytes: Option<u64>,
    pub measured_peak_provenance: GraphMeasuredPeakProvenance,
}

Fixed-shape measured-peak observation for one graph attempt.

The engine creates one of these before it enters the graph executor and fills the runtime measurement when that attempt leaves it. It is diagnostic only: the row cannot mint admission evidence or modify a device grant. node_index is typed executor identity; report consumers should use node_id.

Fields

query_id: Option<QueryId>

Query-wide diagnostic correlation id, when the execution context has one. The runtime metrics owner assigns this sequence.

node_id: String

Stable native graph node id for reports.

node_index: usize

Typed graph node identity used to correlate the post-execution sample without parsing a report string.

algorithm: GraphAlgorithm

The graph algorithm that owned this measured peak.

execution_state: GraphClaimExecutionState

Exact engine state at the graph executor boundary.

measured_peak_bytes: Option<u64>

Measured graph-stage peak bytes when a runtime observation completed.

measured_peak_provenance: GraphMeasuredPeakProvenance

Source of Self::measured_peak_bytes.

Implementations

impl GraphMeasuredPeakRow

pub fn pending( query_id: Option<QueryId>, node_id: impl Into<String>, node_index: usize, algorithm: GraphAlgorithm, ) -> Self

Opens a pending observation for one graph plan node.

pub fn record_measured_peak( &mut self, measured_peak_bytes: Option<u64>, measured_peak_provenance: GraphMeasuredPeakProvenance, )

Records the one direct peak observation for this graph attempt.

An unavailable source always clears the measured value. A zero high-water mark remains an observed zero.

pub fn to_json(&self) -> Value

Serializes this measured-peak row as named JSON.

Trait Implementations

impl Clone for GraphMeasuredPeakRow

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 GraphMeasuredPeakRow

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

Formats the value using the given formatter.

impl Eq for GraphMeasuredPeakRow

impl PartialEq for GraphMeasuredPeakRow

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for GraphMeasuredPeakRow