Struct ArrivalLog 

pub struct ArrivalLog { /* private fields */ }

Append-only log of per-stop arrival events used to compute rolling arrival-rate signals.

Stored as a Vec<(tick, stop)> sorted by tick (records are appended in tick order during normal sim execution). Queries are O(n) worst case but typically O(window_size); prune_before keeps the tail short enough that this is a non-issue for practical window sizes.

Implementations

impl ArrivalLog

pub fn record(&mut self, tick: u64, stop: EntityId)

Record an arrival at stop on tick.

pub fn arrivals_in_window( &self, stop: EntityId, now: u64, window_ticks: u64, ) -> u64

Count arrivals at stop within the window [now - window, now] inclusive. window_ticks = 0 always returns 0.

pub fn prune_before(&mut self, cutoff: u64)

Drop every entry with tick strictly before cutoff. Called each tick by the sim with cutoff = current_tick - max_window so the log can’t grow without bound.

pub const fn len(&self) -> usize

Number of recorded events currently in the log. Intended for snapshot inspection and tests.

pub const fn is_empty(&self) -> bool

Whether the log has no recorded events.

pub fn remap_entity_ids(&mut self, id_remap: &HashMap<EntityId, EntityId>)

Rewrite every entry’s stop EntityId through id_remap, dropping entries whose stop isn’t present in the map. Used by snapshot restore to translate pre-restore stop IDs to the new allocations.

Trait Implementations

impl Clone for ArrivalLog

fn clone(&self) -> ArrivalLog

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ArrivalLog

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

Formats the value using the given formatter.

impl Default for ArrivalLog

fn default() -> ArrivalLog

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ArrivalLog

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ArrivalLog

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.