Struct TopologySnapshot 

pub struct TopologySnapshot {
    pub peer_addr: SocketAddr,
    pub location: f64,
    pub contracts: HashMap<ContractInstanceId, ContractSubscription>,
    pub active_subscription_keys: HashSet<ContractInstanceId>,
    pub timestamp_nanos: u64,
    pub connection_count: usize,
}

A snapshot of a peer’s complete subscription topology.

Fields

peer_addr: SocketAddr

The peer’s socket address

location: f64

The peer’s ring location (for proximity analysis)

contracts: HashMap<ContractInstanceId, ContractSubscription>

Subscriptions per contract

active_subscription_keys: HashSet<ContractInstanceId>

Keys present in this peer’s HostingManager::active_subscriptions map.

Unlike the contracts map (which is merged with the hosting cache and may hide active-subscription presence behind is_hosting=true), this field is a direct projection of active_subscriptions with no merge. Tests that need to detect whether a peer installed a subscription lease — as opposed to merely caching the contract — should read this.

timestamp_nanos: u64

Timestamp when this snapshot was taken (for staleness detection)

connection_count: usize

The peer’s current established ring-connection count at snapshot time.

Stamped by the snapshot registration sites (which hold the live ConnectionManager), not by generate_topology_snapshot (which runs on the HostingManager and has no connection view). 0 when unstamped. Used as a join/peer_ready progress signal — unlike snapshot presence (gated only on get_own_addr(), which is the bind address and set early), a non-zero connection count means the peer has completed at least one handshake and can originate operations. See SimNetwork::wait_for_join_convergence_before_ops.

Implementations

impl TopologySnapshot

pub fn new(peer_addr: SocketAddr, location: f64) -> Self

Create a new empty topology snapshot for a peer.

pub fn set_contract( &mut self, contract_id: ContractInstanceId, subscription: ContractSubscription, )

Add or update a contract subscription.

pub fn get_contract( &self, contract_id: &ContractInstanceId, ) -> Option<&ContractSubscription>

Get the subscription for a contract.

pub fn has_upstream(&self, contract_id: &ContractInstanceId) -> bool

Check if this peer has an upstream for a contract.

pub fn is_hosting(&self, contract_id: &ContractInstanceId) -> bool

Check if this peer is hosting a contract.

Trait Implementations

impl Clone for TopologySnapshot

fn clone(&self) -> TopologySnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TopologySnapshot

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

Formats the value using the given formatter.