Struct GrpcConnectionAsync 

pub struct GrpcConnectionAsync { /* private fields */ }

Async gRPC connection to a Hyper database (query-only).

This is the async version of GrpcConnection, designed for use with tokio-based async applications.

Example

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mut conn = GrpcConnectionAsync::connect(
        "http://localhost:7484",
        "my_database.hyper"
    ).await?;

    let arrow_data = conn.execute_query_to_arrow("SELECT * FROM users").await?;
    Ok(())
}

Implementations

impl GrpcConnectionAsync

pub async fn connect(endpoint: &str, database_path: &str) -> Result<Self>

Connects to a Hyper server via gRPC (async).

Arguments

• endpoint - The gRPC endpoint URL (e.g., “http://localhost:7484”)
• database_path - Path to the database to query

Errors

Returns crate::Error::Client if the HTTP/2 channel cannot be established (endpoint unreachable, TLS handshake failure).

pub async fn connect_with_config(config: GrpcConfig) -> Result<Self>

Connects to a Hyper server via gRPC with custom configuration (async).

Errors

Returns crate::Error::Client if the HTTP/2 channel cannot be established with the supplied configuration.

pub async fn execute_query_to_arrow(&mut self, sql: &str) -> Result<Bytes>

Executes a SQL query and returns raw Arrow IPC bytes (async).

Errors

Returns crate::Error::Client if the server rejects the query or the HTTP/2 channel fails mid-stream.

pub async fn execute_query(&mut self, sql: &str) -> Result<GrpcQueryResult>

Executes a SQL query and returns a structured result (async).

Errors

Returns crate::Error::Client if the server rejects the query or the HTTP/2 channel fails.

pub async fn cancel_query(&mut self, query_id: &str) -> Result<()>

Cancels an in-flight gRPC query by its query_id (async).

See GrpcConnection::cancel_query for full semantics, including the “Fallible by design” discussion of why this returns Result<()> and why it is not an implementation of the Cancellable trait. The async variant avoids blocking the current thread; both variants route the cancel over the same channel used for queries, carrying this connection’s database routing and custom headers.

Example

conn.cancel_query(query_id).await?;

Errors

See GrpcConnection::cancel_query.

pub fn database(&self) -> Option<&str>

Returns the database path, if one is attached.

pub fn config(&self) -> &GrpcConfig

Returns the gRPC configuration.

pub async fn close(self) -> Result<()>

Closes the connection (async).

Errors

Returns crate::Error::Client if the underlying HTTP/2 channel cannot be shut down cleanly.

Trait Implementations

impl Debug for GrpcConnectionAsync

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

Formats the value using the given formatter.