Function execute_query 

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

Execute a query on the blocking thread pool with timeout.

This function:

1. Spawns the query execution on tokio’s blocking thread pool
2. Applies a timeout to prevent stuck queries from hanging indefinitely
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::TaskPanic) - If the blocking task panics
• 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?;