Struct CovSubscriptionManager 

pub struct CovSubscriptionManager { /* private fields */ }

Tracks active COV subscriptions and generates notifications on property changes.

Implementations

impl CovSubscriptionManager

pub fn new() -> Self

Create an empty subscription manager.

pub fn subscribe( &self, subscriber_process_id: u32, monitored_object_id: ObjectId, subscriber_address: DataLinkAddress, issue_confirmed: bool, lifetime_seconds: Option<u32>, )

Add or renew a subscription. If a subscription with the same (process_id, object_id) already exists, it is renewed.

pub fn cancel(&self, subscriber_process_id: u32, monitored_object_id: ObjectId)

Cancel a subscription identified by (process_id, object_id).

pub fn purge_expired(&self)

Remove expired subscriptions.

pub fn subscribers_for( &self, object_id: ObjectId, ) -> Vec<(DataLinkAddress, u32, bool)>

Get all active subscribers for a given object. Returns (subscriber_address, subscriber_process_id, issue_confirmed).

pub fn active_count(&self) -> usize

Return the count of active (non-expired) subscriptions.

Trait Implementations

impl Default for CovSubscriptionManager

fn default() -> Self

Returns the “default value” for a type.