Struct TrajectoryRecorder 

pub struct TrajectoryRecorder { /* private fields */ }

Plugin that filters AgentEvents into TrajectoryRecords and forwards to a TrajectorySink. Stamps each record with a monotonic per-run sequence number and resolves the run id from AgentEvent::RunIdentified.

Register as an EventObserver on the parent run; child runs that reuse the same recorder share the sequence space and stay distinguishable by run_id/parent_run_id. For a strict per-run sequence reset, register a fresh recorder per spawn.

Implementations

impl TrajectoryRecorder

pub fn new(sink: Arc<dyn TrajectorySink>) -> Self

Trait Implementations

impl EventObserver for TrajectoryRecorder

fn on_event<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 AgentEvent, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Plugin for TrajectoryRecorder

fn name(&self) -> &'static str

Stable identifier for logs and telemetry.

fn capabilities(&self) -> PluginCapabilities

Which capabilities this plugin implements. Default: none — meaning pure observation by inheriting from EventObserver. Override and return the relevant set when adding behavior.