Struct AsyncMongrelClient 

pub struct AsyncMongrelClient { /* private fields */ }

Async counterpart for Kit and health calls.

Implementations

impl AsyncMongrelClient

pub fn builder(url: impl AsRef<str>) -> AsyncMongrelClientBuilder

pub fn new(url: &str) -> ClientResult<Self>

pub fn with_options( url: impl AsRef<str>, options: RemoteOptions, ) -> ClientResult<Self>

pub fn try_with_bearer_token(self, token: impl AsRef<str>) -> ClientResult<Self>

pub fn with_bearer_token(self, token: impl AsRef<str>) -> ClientResult<Self>

pub fn try_with_basic_auth( self, username: impl AsRef<str>, password: impl AsRef<str>, ) -> ClientResult<Self>

pub fn with_basic_auth( self, username: impl AsRef<str>, password: impl AsRef<str>, ) -> ClientResult<Self>

pub async fn health(&self) -> ClientResult<String>

pub async fn capabilities(&self) -> ClientResult<ServerCapabilities>

pub async fn sql_cancellation_capabilities( &self, ) -> ClientResult<SqlCancellationCapabilities>

pub async fn sql_idempotency_capabilities( &self, ) -> ClientResult<SqlIdempotencyCapabilities>

pub async fn sql_pagination_capabilities( &self, ) -> ClientResult<SqlPaginationCapabilities>

pub async fn sql(&self, sql: &str) -> ClientResult<Vec<RecordBatch>>

pub async fn sql_with_options( &self, sql: &str, options: SqlClientOptions, ) -> ClientResult<Vec<RecordBatch>>

pub async fn sql_write_idempotent( &self, sql: &str, idempotency_key: impl Into<String>, ) -> ClientResult<RemoteSqlReceipt>

pub async fn sql_write_idempotent_with_options( &self, sql: &str, idempotency_key: impl Into<String>, options: SqlClientOptions, ) -> ClientResult<RemoteSqlReceipt>

pub async fn sql_page( &self, sql: &str, options: SqlPageOptions, ) -> ClientResult<RemoteSqlPage>

pub async fn continue_sql_page( &self, cursor: &str, options: RemoteSqlControlOptions, ) -> ClientResult<RemoteSqlPage>

pub async fn cancel_sql( &self, query_id: QueryId, ) -> ClientResult<RemoteCancelOutcome>

pub async fn query_status( &self, query_id: QueryId, ) -> ClientResult<RemoteQueryStatus>

pub async fn kit_schema(&self, table: &str) -> ClientResult<TableSchemaInfo>

Fetch one table’s schema + constraint metadata (GET /kit/schema/{t}).

pub async fn kit_txn(&self, req: &KitTxnRequest) -> ClientResult<KitTxnResponse>

Run a typed atomic batch (POST /kit/txn).

pub async fn kit_query( &self, req: &KitQueryRequest, ) -> ClientResult<KitQueryResponse>

Run a native typed query (POST /kit/query).

pub async fn kit_retrieve( &self, req: &KitRetrieveRequest, ) -> ClientResult<KitRetrieveResponse>

pub async fn kit_retrieve_with_options( &self, req: &KitRetrieveRequest, options: &AiExecutionOptions, ) -> ClientResult<KitRetrieveResponse>

pub async fn kit_ann_rerank( &self, req: &KitAnnRerankRequest, ) -> ClientResult<KitAnnRerankResponse>

pub async fn kit_ann_rerank_with_options( &self, req: &KitAnnRerankRequest, options: &AiExecutionOptions, ) -> ClientResult<KitAnnRerankResponse>

pub async fn kit_set_similarity( &self, req: &KitSetSimilarityRequest, ) -> ClientResult<KitSetSimilarityResponse>

pub async fn kit_set_similarity_with_options( &self, req: &KitSetSimilarityRequest, options: &AiExecutionOptions, ) -> ClientResult<KitSetSimilarityResponse>

pub async fn kit_search( &self, req: &KitSearchRequest, ) -> ClientResult<KitSearchResponse>

pub async fn kit_ai_metrics(&self) -> ClientResult<Value>

Trait Implementations

impl Clone for AsyncMongrelClient

fn clone(&self) -> AsyncMongrelClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.