Struct ActiveSubscription 

pub struct ActiveSubscription {
    pub id: SubscriptionId,
    pub subscription_name: String,
    pub definition: SubscriptionDefinition,
    pub user_context: Value,
    pub variables: Value,
    pub created_at: DateTime<Utc>,
    pub connection_id: String,
    pub rls_conditions: Vec<(String, Value)>,
    pub tenant_id: Option<String>,
    pub plan: Option<Arc<SubscriptionPlan>>,
    pub delivered: Arc<AtomicU64>,
}

A client’s active subscription.

Fields

id: SubscriptionId

Unique subscription ID.

subscription_name: String

Subscription type name from schema.

definition: SubscriptionDefinition

Reference to subscription definition.

user_context: Value

User context for authorization filtering.

variables: Value

Runtime variables provided by client.

created_at: DateTime<Utc>

When the subscription was created.

connection_id: String

Connection/client identifier (for routing).

rls_conditions: Vec<(String, Value)>

Row-level security conditions evaluated at subscribe time.

Each entry is (field_path, expected_value). An event is only delivered when every condition matches the event data (AND semantics). An empty list means no RLS filtering (admin or no RLS policy).

tenant_id: Option<String>

Tenant identifier for multi-tenant isolation.

When set, only events with a matching tenant_id are delivered. Extracted from the subscriber’s JWT fk_customer_org claim at subscribe time.

plan: Option<Arc<SubscriptionPlan>>

What each event is served as for this subscriber (ruling AA 4): planned by the executor at subscribe time from the client’s selection and principal. None for a subscription registered without one.

delivered: Arc<AtomicU64>

Events delivered to this subscription so far (ruling AA 5): the next delivery’s position is one more. Shared by clones, so it counts each delivery once.

Implementations

impl ActiveSubscription

pub fn new( subscription_name: impl Into<String>, definition: SubscriptionDefinition, user_context: Value, variables: Value, connection_id: impl Into<String>, ) -> Self

Create a new active subscription.

Arguments

• subscription_name - Schema subscription name
• definition - Subscription definition from compiled schema
• user_context - Raw user context JSON from WebSocket connection_init
• variables - Runtime variables from client
• connection_id - Client connection identifier

pub fn with_rls_conditions(self, conditions: Vec<(String, Value)>) -> Self

Set row-level security conditions for event filtering.

The caller evaluates the RLS policy against the user’s SecurityContext at subscribe time and converts the resulting WhereClause into (field, value) equality conditions. During event delivery, matches_subscription checks every condition against the event data.

pub fn with_plan(self, plan: Arc<SubscriptionPlan>) -> Self

Serve every event through plan (ruling AA 4).

Trait Implementations

impl Clone for ActiveSubscription

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ActiveSubscription

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.