Struct AtifTrajectoryBuilder 

pub struct AtifTrajectoryBuilder { /* private fields */ }

Stateful collector that converts a live ThreadEvent stream into an ATIF-compliant Trajectory.

Feed events via process_event (timestamps at observation time) or process_event_at (deterministic timestamps for tests). Call finish to produce the final trajectory.

Implementations

impl AtifTrajectoryBuilder

pub fn new(agent: AtifAgent) -> Self

Create a new builder for the given agent.

pub fn set_session_id(&mut self, id: impl Into<String>)

Set the session ID explicitly. If not set, it will be derived from ThreadStarted or ThreadCompleted events.

pub fn process_event(&mut self, event: &ThreadEvent)

Process a thread event using the current wall-clock time.

pub fn process_event_at(&mut self, event: &ThreadEvent, ts: DateTime<Utc>)

Process a thread event with an explicit timestamp (for deterministic tests).

pub fn finish(self, override_metrics: Option<FinalMetrics>) -> Trajectory

Consume the builder and produce the final ATIF trajectory.

Pass optional FinalMetrics to override the accumulated values. If None, final metrics are derived from observed events.

pub fn step_count(&self) -> usize

Returns the number of steps collected so far.

Trait Implementations

impl EventEmitter for AtifTrajectoryBuilder

fn emit(&mut self, event: &ThreadEvent)

Invoked for each event emitted by the automation runtime.