Struct TrajectoryBuilder 

pub struct TrajectoryBuilder { /* private fields */ }

Per-walker accumulator that the executor pushes steps into and converts to a FlowTrajectory at terminate/error time. Not a FlowLogSink — the executor explicitly emits one event from the finalized trajectory.

Implementations

impl TrajectoryBuilder

pub fn new(conn: ConnId, entry: NodeId, started_at_ms: u64) -> Self

pub fn placeholder(conn: ConnId, started_at_ms: u64) -> Self

Detached builder used as a transient placeholder when the owning FlowCtx needs to swap its trajectory out via std::mem::replace (finalize consumes by value, so the FlowCtx must hold something in the slot during the call).

The resulting builder records no entry node and is discarded immediately after the swap — callers must not push steps to it or finalize it as if it represented a real trace.

pub fn push(&mut self, step: TrajectoryStep)

pub fn finalize( self, outcome: TrajectoryOutcome, finished_at_ms: u64, ) -> FlowTrajectory

Trait Implementations

impl Debug for TrajectoryBuilder

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

Formats the value using the given formatter.