Struct NetworkTopologyMapper 

pub struct NetworkTopologyMapper { /* private fields */ }

Live network topology mapper.

Tracks peer nodes and directed edges, computes graph algorithms, and maintains a bounded ring-buffer of snapshots.

Implementations

impl NetworkTopologyMapper

pub fn new(config: NtmMapperConfig) -> Self

Create a new mapper with the given config.

pub fn with_defaults() -> Self

Create a mapper with default configuration.

pub fn add_node( &mut self, id: NtmNodeId, addr: impl Into<String>, region: Option<String>, rtt_ms: f64, last_seen: u64, ) -> Result<(), NtmMapperError>

Insert or update a node.

If the node already exists its addr, region, rtt_ms, and last_seen fields are refreshed. Returns Err(CapacityExceeded) when the node is new and the graph is full.

pub fn remove_node(&mut self, id: &NtmNodeId) -> Result<(), NtmMapperError>

Remove a node and all edges incident to it.

pub fn update_node_rtt( &mut self, id: &NtmNodeId, rtt_ms: f64, ) -> Result<(), NtmMapperError>

Update the RTT measurement for an existing node.

pub fn set_bootstrap( &mut self, id: &NtmNodeId, flag: bool, ) -> Result<(), NtmMapperError>

Mark a node as a bootstrap / well-known anchor.

pub fn get_node(&self, id: &NtmNodeId) -> Option<&NtmNode>

Return an immutable reference to a node.

pub fn nodes(&self) -> impl Iterator<Item = &NtmNode>

Iterate over all nodes.

pub fn add_edge( &mut self, src: NtmNodeId, dst: NtmNodeId, latency_ms: f64, bandwidth_kbps: f64, observed_at: u64, ) -> Result<NtmEdgeId, NtmMapperError>

Insert a directed edge src → dst.

If an edge with the same (src, dst) pair already exists, its latency_ms, bandwidth_kbps, and observed_at fields are updated. Returns the edge identifier.

pub fn remove_edge(&mut self, id: NtmEdgeId) -> Result<(), NtmMapperError>

Remove a directed edge by its identifier.

pub fn update_edge_latency( &mut self, id: NtmEdgeId, latency_ms: f64, ) -> Result<(), NtmMapperError>

Update the latency measurement for an existing edge.

pub fn get_edge(&self, id: NtmEdgeId) -> Option<&NtmEdge>

Return an immutable reference to an edge.

pub fn find_edge(&self, src: &NtmNodeId, dst: &NtmNodeId) -> Option<NtmEdgeId>

Return the edge identifier for the directed pair (src, dst), if any.

pub fn edges(&self) -> impl Iterator<Item = &NtmEdge>

Iterate over all edges.

pub fn neighbors(&self, node_id: &NtmNodeId) -> Vec<NtmNodeId>

Return the neighbour node ids reachable via outgoing edges from node_id.

pub fn shortest_path( &self, src: &NtmNodeId, dst: &NtmNodeId, ) -> Option<Vec<NtmNodeId>>

Dijkstra shortest path from src to dst weighted by latency_ms.

Returns None if either node is unknown or no path exists.

pub fn bfs_distance(&self, src: &NtmNodeId, dst: &NtmNodeId) -> Option<u32>

BFS-based shortest path counting hops (ignores weights).

Returns None if no path exists.

pub fn diameter(&self) -> u32

Graph diameter: maximum of all pairwise BFS distances.

Returns 0 when the graph has fewer than two nodes.

pub fn clustering_coefficient(&self, node_id: &NtmNodeId) -> f64

Local clustering coefficient for node_id.

C(u) = triangles / (k * (k-1)) where k = degree(u). Returns 0.0 for nodes with degree < 2.

pub fn compute_betweenness_centrality(&self) -> HashMap<NtmNodeId, f64>

Brandes algorithm for betweenness centrality on the directed graph.

Complexity O(V * E) — suitable for moderate-sized graphs (≤ 4096 nodes).

pub fn take_snapshot(&mut self, ts: u64) -> NtmSnapshot

Capture the current state into a snapshot and store it.

If the snapshot buffer is full (20 entries) the oldest entry is dropped before the new one is inserted.

pub fn snapshots(&self) -> &VecDeque<NtmSnapshot>

Access the snapshot history (oldest first).

pub fn prune_stale(&mut self, now_ts: u64)

Remove all nodes (and their edges) whose last_seen is older than now_ts - config.prune_disconnected_after_secs.

pub fn topology_stats(&self) -> NtmTopologyMetrics

Compute the full suite of topology metrics.

pub fn node_count(&self) -> usize

Return the number of nodes.

pub fn edge_count(&self) -> usize

Return the number of edges.

pub fn config(&self) -> &NtmMapperConfig

Return the current configuration.