Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Manages the lifecycle and in-memory indexing of active subscriptions.

Implementations

impl SubscriptionManager

pub fn new( topic_registry: Arc<InMemoryTopicRegistry>, supported_channels: Vec<String>, ) -> Self

Creates a new subscription manager.

pub fn register( &self, tenant_id: &str, subscription_id: &str, resource: &Value, fhir_version: FhirVersion, ) -> Result<ActiveSubscription, SubscriptionError>

Registers a subscription from a FHIR Subscription resource JSON.

Validates the topic URL, channel type, and filter criteria. On success, the subscription is stored in the in-memory index.

pub fn deregister(&self, tenant_id: &str, subscription_id: &str) -> bool

Removes a subscription from the in-memory index.

pub fn active_subscriptions_for_topic( &self, tenant_id: &str, topic_url: &str, ) -> Vec<ActiveSubscription>

Returns all active subscriptions for a given topic URL within a tenant.

pub fn get_subscription( &self, tenant_id: &str, subscription_id: &str, ) -> Option<ActiveSubscription>

Gets the current status of a subscription.

pub fn update_status( &self, tenant_id: &str, subscription_id: &str, new_status: SubscriptionStatusCode, ) -> Result<SubscriptionStatusCode, SubscriptionError>

Updates the status of a subscription.

pub fn increment_event_count( &self, tenant_id: &str, subscription_id: &str, ) -> Option<u64>

Increments the event counter and returns the new value.

pub fn record_failure( &self, tenant_id: &str, subscription_id: &str, ) -> Option<u32>

Records a delivery failure and returns the new consecutive failure count.

pub fn reset_failures(&self, tenant_id: &str, subscription_id: &str)

Resets the consecutive failure counter after a successful delivery.

pub fn all_subscriptions(&self) -> Vec<ActiveSubscription>

Returns all subscriptions (for heartbeat checking, initialization, etc.).