Struct TrajectoryBuffer 

pub struct TrajectoryBuffer { /* private fields */ }

Lock-free trajectory buffer using crossbeam ArrayQueue

Implementations

impl TrajectoryBuffer

pub fn new(capacity: usize) -> Self

Create new buffer with capacity

pub fn record(&self, trajectory: QueryTrajectory) -> bool

Record trajectory (non-blocking)

Returns true if recorded, false if buffer full

pub fn pop(&self) -> Option<QueryTrajectory>

Try to pop single trajectory

pub fn drain(&self) -> Vec<QueryTrajectory>

Drain all trajectories

pub fn drain_n(&self, n: usize) -> Vec<QueryTrajectory>

Drain up to n trajectories

pub fn len(&self) -> usize

Get current length

pub fn is_empty(&self) -> bool

Check if empty

pub fn is_full(&self) -> bool

Check if full

pub fn capacity(&self) -> usize

Get capacity

pub fn dropped_count(&self) -> u64

Get dropped count

pub fn total_seen(&self) -> u64

Get total seen count

pub fn success_rate(&self) -> f64

Get success rate

pub fn reset_stats(&self)

Reset statistics (not the buffer contents)

pub fn get_all(&self) -> Vec<QueryTrajectory>

Get all trajectories (drains buffer - use for export)

Note: This drains the buffer, so trajectories are removed after this call. For export purposes, this is usually what you want since you’ll re-record new trajectories during continued operation.