Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Group-based subscription manager using sharded concurrent data structures.

Primary index: groups by QueryGroupId (DashMap, 64 shards). Secondary: lookup key -> QueryGroupId for dedup. Subscribers stored in a HashMap for O(1) insert/remove by key. Session -> subscribers mapping for cleanup.

Implementations

impl SubscriptionManager

pub fn new(max_per_session: usize) -> Self

Create a new subscription manager.

pub fn subscribe( &self, session_id: SessionId, client_sub_id: String, query_name: &str, args: &Value, auth_context: &AuthContext, table_deps: &'static [&'static str], selected_cols: &'static [&'static str], ) -> Result<(QueryGroupId, SubscriptionId, bool)>

Subscribe to a query group. Returns the group ID and whether this is a new group. If a group already exists for this query+args+auth_scope, the subscriber joins it.

pub fn unsubscribe(&self, subscription_id: SubscriptionId)

Remove a subscriber by its subscription ID.

pub fn remove_session_subscriptions( &self, session_id: SessionId, ) -> Vec<SubscriptionId>

Remove all subscriptions for a session.

pub fn find_affected_groups(&self, change: &Change) -> Vec<QueryGroupId>

Find all groups affected by a change. Returns group IDs (not subscription IDs). This is O(groups_for_table), not O(all_subscriptions).

pub fn get_group( &self, group_id: QueryGroupId, ) -> Option<Ref<'_, QueryGroupId, QueryGroup>>

Get a reference to a group by ID.

pub fn get_group_mut( &self, group_id: QueryGroupId, ) -> Option<RefMut<'_, QueryGroupId, QueryGroup>>

Get a mutable reference to a group by ID.

pub fn get_group_subscribers( &self, group_id: QueryGroupId, ) -> Vec<(SessionId, String)>

Get all subscriber info for a group (for fan-out).

pub fn update_group( &self, group_id: QueryGroupId, read_set: ReadSet, result_hash: String, )

Update a group after re-execution.

pub fn counts(&self) -> SubscriptionCounts

Get subscription counts.

pub fn group_count(&self) -> usize

Get group count.