Function execute_query 

pub async fn execute_query(
    engine: StandardEngine,
    query: String,
    identity: Identity,
    params: Params,
    timeout: Duration,
) -> ExecuteResult<Vec<Frame>>

Execute a query with timeout.

This function:

1. Starts the async query execution (internally uses spawn_blocking)
2. Collects the stream with a timeout
3. Returns the query results or an appropriate error

Arguments

• engine - The database engine to execute the query on
• query - The RQL query string
• identity - The identity context for permission checking
• params - Query parameters
• timeout - Maximum time to wait for query completion

Returns

• Ok(Vec<Frame>) - Query results on success
• Err(ExecuteError::Timeout) - If the query exceeds the timeout
• Err(ExecuteError::Cancelled) - If the query was cancelled
• Err(ExecuteError::Engine) - If the engine returns an error

Example

let result = execute_query(
    engine,
    "SELECT * FROM users".to_string(),
    identity,
    Params::None,
    Duration::from_secs(30),
).await?;