Struct DiscoveredEndpointsCache 

pub struct DiscoveredEndpointsCache { /* private fields */ }

In-memory cache for SEDP-discovered endpoints.

Implementations

impl DiscoveredEndpointsCache

pub fn new(caps: CacheCaps) -> Self

New with the given caps.

pub fn publications_len(&self) -> usize

Total number of publications.

pub fn subscriptions_len(&self) -> usize

Total number of subscriptions.

pub fn evicted_count(&self) -> u64

Number of LRU evictions since start (DoS diagnostics).

pub fn publication(&self, key: Guid) -> Option<&DiscoveredPublication>

Looks up a publication by endpoint GUID.

pub fn subscription(&self, key: Guid) -> Option<&DiscoveredSubscription>

Looks up a subscription by endpoint GUID.

pub fn publications_for( &self, prefix: GuidPrefix, ) -> impl Iterator<Item = &DiscoveredPublication> + '_

Iterates all publications of a remote participant.

pub fn subscriptions_for( &self, prefix: GuidPrefix, ) -> impl Iterator<Item = &DiscoveredSubscription> + '_

Iterates all subscriptions of a remote participant.

pub fn publications(&self) -> impl Iterator<Item = &DiscoveredPublication> + '_

Iterates all publications (for the matching scan).

pub fn subscriptions( &self, ) -> impl Iterator<Item = &DiscoveredSubscription> + '_

Iterates all subscriptions.

pub fn insert_publication( &mut self, data: PublicationBuiltinTopicData, now: Duration, ) -> bool

Insert or update of a publication. Idempotent: for an already-present GUID, data is overwritten and discovered_at is updated — no eviction round.

On a new insert: if this participant’s publication count reaches the cap, the oldest publication of the same participant is discarded (LRU) and evicted_count is incremented.

Returns: true = newly inserted, false = update.

pub fn insert_subscription( &mut self, data: SubscriptionBuiltinTopicData, now: Duration, ) -> bool

Insert or update of a subscription. Semantics analogous to Self::insert_publication.

pub fn remove_publication(&mut self, key: Guid) -> Option<DiscoveredPublication>

Removes a publication by GUID (e.g. after an explicit withdrawal notification from the remote).

pub fn remove_subscription( &mut self, key: Guid, ) -> Option<DiscoveredSubscription>

Removes a subscription by GUID.

pub fn on_participant_lost(&mut self, prefix: GuidPrefix) -> (usize, usize)

Removes all publications and subscriptions of a remote participant. Called e.g. on an SPDP lease timeout.

Returns: (removed_pubs, removed_subs).

pub fn match_publications<'a>( &'a self, topic: &'a str, type_name: &'a str, ) -> impl Iterator<Item = &'a DiscoveredPublication> + 'a

Finds all publications matching a (topic_name, type_name) — for reader-side matching (T4/T5).

pub fn match_subscriptions<'a>( &'a self, topic: &'a str, type_name: &'a str, ) -> impl Iterator<Item = &'a DiscoveredSubscription> + 'a

Finds all subscriptions matching a (topic_name, type_name) — for writer-side matching.

pub fn publication_keys(&self) -> Vec<Guid>

Collects the GUIDs of all publications (for snapshot tests / diagnostics).

pub fn topic_name_conflicts(&self, topic: &str, type_name: &str) -> bool

True if any discovered publication OR subscription carries the given topic_name but a different type_name — the DDS 1.4 §2.2.4.2.4 inconsistent-topic condition (same topic, incompatible type). Used by the matching path to raise on_inconsistent_topic.

Trait Implementations

impl Clone for DiscoveredEndpointsCache

fn clone(&self) -> DiscoveredEndpointsCache

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DiscoveredEndpointsCache

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

Formats the value using the given formatter.

impl Default for DiscoveredEndpointsCache

fn default() -> DiscoveredEndpointsCache

Returns the “default value” for a type.