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 contains( &self, mac: &MacAddr, network: Option<&NpduAddress>, process_id: u32, monitored_object: ObjectIdentifier, monitored_property: Option<PropertyIdentifier>, ) -> bool

Whether a subscription key is already present.

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 unsubscribe_at( &mut self, mac: &[u8], network: Option<&NpduAddress>, process_id: u32, monitored_object: ObjectIdentifier, ) -> bool

Remove a whole-object subscription for a specific subscriber endpoint.

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

Unsubscribe a per-property subscription.

pub fn unsubscribe_property_at( &mut self, mac: &[u8], network: Option<&NpduAddress>, process_id: u32, monitored_object: ObjectIdentifier, monitored_property: PropertyIdentifier, ) -> bool

Unsubscribe a per-property subscription for a specific subscriber endpoint.

pub fn unsubscribe_cov_multiple_context( &mut self, mac: &[u8], network: Option<&NpduAddress>, process_id: u32, confirmed: bool, )

Remove every COV-multiple subscription in a subscriber context.

pub fn unsubscribe_cov_multiple_property_at( &mut self, mac: &[u8], network: Option<&NpduAddress>, process_id: u32, confirmed: bool, monitored_object: ObjectIdentifier, monitored_property: PropertyIdentifier, )

Remove one property from a COV-multiple subscriber context.

pub fn refresh_cov_multiple_context_lifetime( &mut self, mac: &[u8], network: Option<&NpduAddress>, process_id: u32, confirmed: bool, expires_at: Option<Instant>, )

Refresh the lifetime for an existing COV-multiple subscriber context.

pub fn remove_for_object(&mut self, oid: ObjectIdentifier)

Remove all subscriptions for a given object (used on DeleteObject).

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], network: Option<&NpduAddress>, process_id: u32, monitored_object: ObjectIdentifier, monitored_property: Option<PropertyIdentifier>, 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.