Struct HttpEngine 

pub struct HttpEngine { /* private fields */ }

Authenticated client for the SQL API shared by local and Cloud UQA nodes.

Implementations

impl HttpEngine

pub fn new( base_url: &str, credential: SecretString, ) -> Result<Self, HttpEngineError>

Connect to one UQA data-plane origin.

Plain HTTP is accepted only for loopback local nodes. Cloud endpoints must use HTTPS.

pub fn from_env() -> Result<Self, HttpEngineError>

Read UQA_URL and UQA_TOKEN, as emitted by uqa ... connection --format env.

pub async fn local(project: &str) -> Result<Self, HttpEngineError>

Resolve a local project through the installed uqa CLI, then connect to its data plane.

The CLI is invoked only during construction. Subsequent SQL calls use HTTP directly.

pub async fn local_with_cli( project: &str, cli_path: impl AsRef<OsStr>, ) -> Result<Self, HttpEngineError>

Resolve a local project through a specific uqa CLI executable.

pub async fn cloud( project: &str, organization: Option<&str>, ) -> Result<Self, HttpEngineError>

Resolve a Cloud project and optional organization through the installed uqa CLI.

Passing None uses the CLI’s current default organization. The CLI is invoked only during construction; subsequent SQL calls use HTTP directly.

pub async fn cloud_with_cli( project: &str, organization: Option<&str>, cli_path: impl AsRef<OsStr>, ) -> Result<Self, HttpEngineError>

Resolve a Cloud project through a specific uqa CLI executable.

pub async fn sql( &self, query: &str, params: &[SQLParam], ) -> Result<SQLResult, HttpEngineError>

Execute one materialized SQL statement through POST /v1/sql.

pub async fn sql_with_metadata( &self, query: &str, params: &[SQLParam], ) -> Result<SQLExecution, HttpEngineError>

Execute one materialized SQL statement and preserve its request ID.

pub async fn sql_batch( &self, statements: &[(&str, &[SQLParam])], ) -> Result<Vec<SQLResult>, HttpEngineError>

Execute every statement atomically through POST /v1/sql/batch.

pub async fn sql_batch_with_metadata( &self, statements: &[(&str, &[SQLParam])], ) -> Result<SQLBatchExecution, HttpEngineError>

Execute an atomic SQL batch and preserve its request ID.

pub async fn sql_stream( &self, query: &str, params: &[SQLParam], ) -> Result<SQLStream, HttpEngineError>

Start an incremental SQL request through POST /v1/sql/stream.

Trait Implementations

impl AsyncSQLEngine for HttpEngine

type Error = HttpEngineError

async fn sql<'a>( &'a self, query: &'a str, params: &'a [SQLParam], ) -> Result<SQLResult, Self::Error>

async fn sql_batch<'a>( &'a self, statements: &'a [(&'a str, &'a [SQLParam])], ) -> Result<Vec<SQLResult>, Self::Error>

impl Clone for HttpEngine

fn clone(&self) -> HttpEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HttpEngine

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

Formats the value using the given formatter.