Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Subscription manager for managing Pub/Sub subscriptions.

Uses the google-cloud-pubsub 0.33 SubscriptionAdmin client for subscription management and tracks subscriptions in a local cache.

Implementations

impl SubscriptionManager

pub async fn new(project_id: impl Into<String>) -> Result<Self>

Creates a new subscription manager.

pub async fn create_subscription( &self, config: SubscriptionCreateConfig, ) -> Result<String>

Creates a new subscription.

pub fn get_subscription(&self, subscription_name: &str) -> Option<String>

Gets a fully-qualified subscription name by short name.

pub async fn delete_subscription(&self, subscription_name: &str) -> Result<()>

Deletes a subscription.

pub fn list_subscriptions(&self) -> Vec<String>

Lists all subscriptions.

pub fn subscription_exists(&self, subscription_name: &str) -> bool

Checks if a subscription exists.

pub fn subscription_count(&self) -> usize

Gets the number of managed subscriptions.

pub fn clear_cache(&self)

Clears all cached subscriptions.

pub fn project_id(&self) -> &str

Gets the project ID.

pub async fn update_ack_deadline( &self, subscription_name: &str, _ack_deadline_seconds: i64, ) -> Result<()>

Updates subscription acknowledgment deadline.

pub async fn update_labels( &self, subscription_name: &str, _labels: HashMap<String, String>, ) -> Result<()>

Updates subscription labels.

pub async fn get_metadata( &self, subscription_name: &str, ) -> Result<SubscriptionMetadata>

Gets subscription metadata.

pub async fn get_stats( &self, subscription_name: &str, ) -> Result<SubscriptionStats>

Gets subscription statistics.

pub async fn seek_to_timestamp( &self, subscription_name: &str, timestamp: DateTime<Utc>, ) -> Result<()>

Seeks a subscription to a specific timestamp.

pub async fn seek_to_snapshot( &self, subscription_name: &str, snapshot_name: &str, ) -> Result<()>

Seeks a subscription to a specific snapshot.