Struct CovSubscriptionTable 

pub struct CovSubscriptionTable { /* private fields */ }

Table of active COV subscriptions.

Implementations

impl CovSubscriptionTable

pub fn new() -> Self

pub fn subscribe(&mut self, sub: CovSubscription)

Add or update a subscription.

pub fn unsubscribe( &mut self, mac: &[u8], process_id: u32, monitored_object: ObjectIdentifier, ) -> bool

Remove a subscription by subscriber MAC, process identifier, and monitored object.

pub fn subscriptions_for( &mut self, oid: &ObjectIdentifier, ) -> Vec<&CovSubscription>

Get all active (non-expired) subscriptions for a given object.

pub fn set_last_notified_value( &mut self, mac: &[u8], process_id: u32, monitored_object: ObjectIdentifier, value: f32, )

Update the last-notified value for a subscription.

pub fn should_notify( sub: &CovSubscription, current_value: Option<f32>, cov_increment: Option<f32>, ) -> bool

Check if a COV notification should fire for a subscription given the current present_value and the object’s COV_Increment.

Returns true if:

• No COV_Increment (binary/multi-state objects — always notify)
• No previous notified value (first notification)
• |current - last_notified| >= cov_increment

pub fn len(&self) -> usize

Number of active subscriptions.

pub fn is_empty(&self) -> bool

Whether the table is empty.

pub fn purge_expired(&mut self) -> usize

Remove all expired subscriptions. Returns the number removed.

Trait Implementations

impl Debug for CovSubscriptionTable

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

Formats the value using the given formatter.

impl Default for CovSubscriptionTable

fn default() -> CovSubscriptionTable

Returns the “default value” for a type.