Skip to main content

execute_subscription

reifydb_sub_server::execute

Function execute_subscription 

Source 
pub async fn execute_subscription(
    system: ActorSystem,
    engine: StandardEngine,
    statement: String,
    identity: IdentityId,
    params: Params,
    timeout: Duration,
) -> ExecuteResult<Vec<Frame>>
Expand description

Execute a subscription operation with timeout.

Subscription operations are restricted to CREATE SUBSCRIPTION and DROP SUBSCRIPTION. This provides security isolation by not granting full admin access to subscription clients.