Struct DiscoveredEndpointsCache 

pub struct DiscoveredEndpointsCache { /* private fields */ }

In-memory Cache fuer SEDP-entdeckte Endpoints.

Implementations

impl DiscoveredEndpointsCache

pub fn new(caps: CacheCaps) -> Self

Neu mit den gegebenen Caps.

pub fn publications_len(&self) -> usize

Anzahl Publications insgesamt.

pub fn subscriptions_len(&self) -> usize

Anzahl Subscriptions insgesamt.

pub fn evicted_count(&self) -> u64

Anzahl LRU-Evictions seit Start (DoS-Diagnose).

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

Lookup einer Publication per Endpoint-GUID.

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

Lookup einer Subscription per Endpoint-GUID.

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

Iteriert alle Publications eines Remote-Participants.

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

Iteriert alle Subscriptions eines Remote-Participants.

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

Iteriert alle Publications (fuer Matching-Scan).

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

Iteriert alle Subscriptions.

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

Insert oder Update einer Publication. Idempotent: bei bereits vorhandener GUID wird data ueberschrieben und discovered_at aktualisiert — keine Eviction-Runde.

Bei neuem Insert: wenn die Publications-Zahl dieses Participants den Cap erreicht, wird die aelteste Publication desselben Participants verworfen (LRU), evicted_count inkrementiert.

Rueckgabe: true = neu eingefuegt, false = Update.

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

Insert oder Update einer Subscription. Semantik analog Self::insert_publication.

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

Entfernt eine Publication per GUID (z.B. nach expliziter Withdrawal-Notification vom Remote).

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

Entfernt eine Subscription per GUID.

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

Entfernt alle Publications und Subscriptions eines Remote- Participants. Aufruf z.B. bei SPDP-Lease-Timeout.

Rueckgabe: (removed_pubs, removed_subs).

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

Findet alle Publications, die zu einem (topic_name, type_name) passen — fuer Reader-seitiges Matching (T4/T5).

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

Findet alle Subscriptions, die zu einem (topic_name, type_name) passen — fuer Writer-seitiges Matching.

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

Sammelt die GUIDs aller Publications (fuer Snapshot-Tests / Diagnose).

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.