Struct PubSubManager 

pub struct PubSubManager { /* private fields */ }

Manager for pub-sub subscriptions and event publishing.

This provides the infrastructure for change notifications. Full change data capture (CDC) integration with the storage layer will be implemented in Phase 6.

Implementations

impl PubSubManager

pub fn new() -> Self

Create a new pub-sub manager.

pub async fn subscribe( &self, client_id: &str, subscription: &Subscription, ) -> Result<u64, Error>

Subscribe to changes for an entity type.

Returns the subscription ID.

pub async fn unsubscribe(&self, subscription_id: u64) -> Result<(), Error>

Unsubscribe from a subscription.

pub async fn publish_event( &self, entity: &str, entity_id: [u8; 16], change_type: ChangeType, changed_fields: Vec<String>, schema_version: u64, )

Publish a change event for an entity.

This queues the event for delivery to matching subscriptions. In Phase 6, this will be connected to the storage layer’s CDC.

pub async fn drain_events(&self) -> Vec<ChangeEvent>

Drain queued events for delivery.

This is used by the transport layer to send events to subscribers.

pub async fn subscription_count(&self) -> usize

Get the number of active subscriptions.

pub async fn subscriptions_for_entity(&self, entity: &str) -> Vec<u64>

Get subscriptions for a specific entity.

pub async fn get_subscription( &self, subscription_id: u64, ) -> Option<SubscriptionEntry>

Get a subscription by ID.

pub async fn remove_client_subscriptions(&self, client_id: &str)

Remove all subscriptions for a client.

Trait Implementations

impl Default for PubSubManager

fn default() -> Self

Returns the “default value” for a type.