Struct ObservationWindow 

pub struct ObservationWindow { /* private fields */ }

Enriched observation horizon with temporal context.

Tracks not just what was observed (origin_hash, sequence) but when and how far away each entity is (staleness, estimated delay).

Implementations

impl ObservationWindow

pub fn new(local_subnet: SubnetId) -> Self

Create a new observation window.

pub fn from_horizon(horizon: ObservedHorizon, local_subnet: SubnetId) -> Self

Create from an existing horizon.

pub fn observe_with_context( &mut self, origin_hash: u64, sequence: u64, hop_count: u8, source_subnet: SubnetId, model: &PropagationModel, )

Record an observation with propagation context.

pub fn observe(&mut self, origin_hash: u64, sequence: u64)

Simple observation (no propagation context).

pub fn staleness(&self, origin_hash: u64) -> Option<Duration>

How long since an entity was last observed.

pub fn is_within_cone(&self, origin_hash: u64, max_delay_nanos: u64) -> bool

Whether an entity is within the observer’s causal cone (observed recently enough given propagation delay).

pub fn reachable_entities(&self, max_delay_nanos: u64) -> Vec<u64>

Entities observed within a given hop radius.

pub fn divergence_from(&self, other: &ObservationWindow) -> HorizonDivergence

Quantify how different two observers’ views are.

pub fn horizon(&self) -> &ObservedHorizon

Get the underlying horizon.

pub fn local_subnet(&self) -> SubnetId

Get the local subnet.

pub fn entity_count(&self) -> usize

Number of observed entities.

Trait Implementations

impl Debug for ObservationWindow

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

Formats the value using the given formatter.