Struct SubscriptionState 

pub struct SubscriptionState {
    pub manager: Arc<SubscriptionManager>,
    pub lifecycle: Arc<dyn SubscriptionLifecycle>,
    pub max_subscriptions_per_connection: Option<u32>,
    pub remote_subscription_fields: Arc<HashMap<String, String>>,
    pub domain_registry: Option<Arc<DomainRegistry>>,
    pub strict_tenant_validation: bool,
    pub authorizer: Option<Arc<dyn Authorizer>>,
    pub tenant_status_source: Option<Arc<dyn TenantStatusSource>>,
}

State for subscription WebSocket handler.

Fields

manager: Arc<SubscriptionManager>

Subscription manager.

lifecycle: Arc<dyn SubscriptionLifecycle>

Lifecycle hooks.

max_subscriptions_per_connection: Option<u32>

Maximum subscriptions per connection (None = unlimited).

remote_subscription_fields: Arc<HashMap<String, String>>

Subscription fields owned by remote subgraphs.

Maps root subscription field name to the subgraph WebSocket URL. Empty when federation is disabled or no remote subscription fields are declared.

domain_registry: Option<Arc<DomainRegistry>>

Host-header → tenant-key domain registry. None until a host binary installs one (mirrors AppState::domain_registry).

strict_tenant_validation: bool

Reject conflicting tenant sources (JWT vs X-Tenant-ID vs Host) on the upgrade. Driven by schema.has_rls_configured(), mirroring the GraphQL handler’s strict tenant validation.

authorizer: Option<Arc<dyn Authorizer>>

Optional operation-level authorizer (#422). When set, each subscription is authorized at establishment with OperationKind::Subscription, the subscription field name, and the connection’s principal. None until a host binary installs one (from Executor::config().authorizer).

tenant_status_source: Option<Arc<dyn TenantStatusSource>>

Optional tenant-status source (M-tenant-ws-suspended). When set, a new subscription whose resolved tenant is suspended is rejected, and event delivery to a connection whose tenant is suspended is paused. None until a host binary installs a multi-tenant registry.

Implementations

impl SubscriptionState

pub fn new(manager: Arc<SubscriptionManager>) -> Self

Create new subscription state.

pub fn with_tenant_status_source( self, source: Option<Arc<dyn TenantStatusSource>>, ) -> Self

Install the tenant-status source (M-tenant-ws-suspended). When set, new subscriptions for a suspended tenant are rejected and event delivery to a suspended tenant is paused. Typically the TenantExecutorRegistry.

pub fn with_authorizer(self, authorizer: Option<Arc<dyn Authorizer>>) -> Self

Install the operation-level authorizer (#422). When set, every subscription is authorized at establishment; a Deny (or any policy error) rejects the subscription with a FORBIDDEN GraphQL-WS error. Typically populated from Executor::config().authorizer.

pub fn with_tenant_context( self, domain_registry: Arc<DomainRegistry>, strict_tenant_validation: bool, ) -> Self

Install the tenant-resolution context — the Host-header domain registry and strict-validation flag — so the subscription upgrade dispatches the tenant key the same way the GraphQL handler does (JWT tenant_id > X-Tenant-ID header > Host domain, with cross-source conflict rejection when strict_tenant_validation is set). See crate::routes::graphql::TenantKeyResolver.

pub fn with_lifecycle(self, lifecycle: Arc<dyn SubscriptionLifecycle>) -> Self

Set lifecycle hooks.

pub const fn with_max_subscriptions(self, max: Option<u32>) -> Self

Set maximum subscriptions per connection.

pub fn with_remote_subscription_fields( self, fields: HashMap<String, String>, ) -> Self

Set remote subscription fields (federation passthrough).

Maps subscription field names to the owning subgraph’s WebSocket URL.

Trait Implementations

impl Clone for SubscriptionState

fn clone(&self) -> SubscriptionState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.