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 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.