Struct StationLoadSampler 

pub struct StationLoadSampler { /* private fields */ }

Runtime helper that derives StationLoadSample from existing low-level state.

Implementations

impl StationLoadSampler

pub const fn new(config: StationLoadSamplerConfig) -> Self

Creates a station load sampler.

pub const fn config(&self) -> StationLoadSamplerConfig

Returns the sampler configuration.

pub fn sample_station( &self, station: &Station, index: Option<&CellIndex>, queued_events: usize, subscribers: usize, ) -> StationLoadSample

Samples one station from its storage, optional index, queued event count, and caller-provided subscriber estimate.

pub fn sample_all( &self, stations: &StationSet, indexes: &StationIndexSet, router: &EventRouter, subscriber_counts: &[(StationId, usize)], ) -> Vec<StationLoadSample>

Samples every station in deterministic station-set order.

subscriber_counts is explicit integration input: SectorSync can use it for load decisions, but does not own gateway/client/session business state. Counts with the same station id are aggregated with saturating arithmetic. Because the event router and subscriber input are station-scoped, their pressure stays on the station sample instead of being invented per cell.

Trait Implementations

impl Clone for StationLoadSampler

fn clone(&self) -> StationLoadSampler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for StationLoadSampler

impl Debug for StationLoadSampler

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

Formats the value using the given formatter.

impl Default for StationLoadSampler

fn default() -> Self

Returns the “default value” for a type.

impl Eq for StationLoadSampler

impl PartialEq for StationLoadSampler

fn eq(&self, other: &StationLoadSampler) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for StationLoadSampler