Struct RecentPeers 

pub struct RecentPeers {
    pub version: u32,
    pub local_npub: String,
    pub scope: String,
    pub peers: BTreeMap<String, RecentPeer>,
}

Store-agnostic version-1 recent-peer document.

The serialized object contains exactly version, local_npub, scope, and peers. Applications choose where and how to persist that JSON.

Fields

version: u32

local_npub: String

scope: String

peers: BTreeMap<String, RecentPeer>

Implementations

impl RecentPeers

pub fn new( local_npub: impl Into<String>, scope: impl Into<String>, ) -> Result<Self, RecentPeersError>

Create an empty version-1 cache for one local identity and app scope.

pub fn from_json( json: &str, expected_local_npub: &str, expected_scope: &str, ) -> Result<Self, RecentPeersError>

Strictly decode and validate a cache for the expected identity/scope.

Unknown fields, unknown transports, wrong versions, invalid identities, unsafe endpoints, and documents exceeding the schema limits are rejected. Identity and scope binding prevents one app or local key from accidentally consuming another’s routing memory.

pub fn to_json(&self) -> Result<String, RecentPeersError>

Validate and encode the canonical compact version-1 JSON document.

pub fn to_json_pretty(&self) -> Result<String, RecentPeersError>

Validate and encode an indented version-1 JSON document.

pub fn local_npub(&self) -> &str

Local identity to which this routing cache is bound.

pub fn scope(&self) -> &str

Application discovery scope to which this routing cache is bound.

pub fn validate(&self) -> Result<(), RecentPeersError>

Validate all schema invariants without decoding or encoding JSON.

pub fn observe_authenticated_peer( &mut self, peer: &FipsEndpointPeer, authenticated_at_ms: u64, ) -> Result<bool, RecentPeersError>

Record one currently authenticated endpoint snapshot.

A connected peer’s identity is retained regardless of transport. Only FipsEndpointPeer::authenticated_udp_restart_addr can add a restart endpoint. A disconnected status/retry entry is ignored because it is not fresh authentication evidence.

Returns true only when the cache contents changed.

pub fn prune(&mut self, now_ms: u64, ttl_ms: u64)

Remove identity and endpoint observations older than ttl_ms.

Identity-only records are intentionally retained for the same TTL as routed records. Future timestamps survive clock rollback by using saturating age arithmetic.

pub fn merge_into_peer_configs(&self, peer_configs: &mut [PeerConfig]) -> usize

Merge cached routes into already-authorized peer configurations.

This method cannot create membership: it only mutates entries in the supplied slice and never calls crate::endpoint::FipsEndpoint::update_peers. Applications remain responsible for deciding which peers belong in that slice. Cached addresses use authenticated provenance and preserve their observation timestamp for retry ranking.

Returns the number of addresses added or refreshed.

Trait Implementations

impl Clone for RecentPeers

fn clone(&self) -> RecentPeers

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RecentPeers

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RecentPeers

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for RecentPeers

impl PartialEq for RecentPeers

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for RecentPeers

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for RecentPeers