Struct GrpcClientSync 

pub struct GrpcClientSync { /* private fields */ }

Synchronous wrapper around GrpcClient.

This provides a blocking API by creating a Tokio runtime internally. For better performance in async contexts, use GrpcClient directly.

Example

use hyperdb_api_core::client::grpc::{GrpcClientSync, GrpcConfig};

let config = GrpcConfig::new("http://localhost:7484")
    .database("test.hyper");

let mut client = GrpcClientSync::connect(config)?;
let result = client.execute_query("SELECT * FROM users")?;
let arrow_bytes = result.arrow_data();

Implementations

impl GrpcClientSync

pub fn connect(config: GrpcConfig) -> Result<GrpcClientSync, Error>

Connects to a Hyper server via gRPC (blocking).

Errors

• Returns ErrorKind::Other if a current-thread Tokio runtime cannot be built.
• Propagates any error from GrpcClient::connect (invalid endpoint, TLS configuration failure, or transport setup failure).

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

Executes a SQL query (blocking).

Errors

Blocking wrapper around GrpcClient::execute_query; see that method for the concrete failure modes.

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

Executes a query and returns Arrow IPC bytes (blocking).

Errors

Same failure modes as Self::execute_query.

pub fn execute_query_stream( &mut self, sql: &str, ) -> Result<GrpcChunkStreamSync, Error>

Executes a query and returns a blocking streaming chunk producer.

See GrpcClient::execute_query_stream for the streaming semantics and memory behavior. The returned GrpcChunkStreamSync lets you pull chunks one at a time without buffering the entire result.

Errors

Same failure modes as GrpcClient::execute_query_stream.

pub fn execute_query_with_params( &mut self, sql: &str, params: QueryParameters, style: ParameterStyle, ) -> Result<GrpcQueryResult, Error>

Executes a parameterized SQL query (blocking).

Example

use hyperdb_api_core::client::grpc::{GrpcClientSync, GrpcConfig, QueryParameters, ParameterStyle};

let params = QueryParameters::json_positional(&[&42i64])?;
let result = client.execute_query_with_params(
    "SELECT * FROM users WHERE id = $1",
    params,
    ParameterStyle::DollarNumbered,
)?;

Errors

Blocking wrapper around GrpcClient::execute_query_with_params; see that method for the concrete failure modes.

pub fn execute_query_with_params_to_arrow( &mut self, sql: &str, params: QueryParameters, style: ParameterStyle, ) -> Result<Bytes, Error>

Executes a parameterized query and returns Arrow IPC bytes (blocking).

Errors

Same failure modes as Self::execute_query_with_params.

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

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

Blocking wrapper around GrpcClient::cancel_query. See that method’s documentation for when a query_id is available (ASYNC-mode queries), best-effort cancel semantics, and the full “Relation to the Cancellable trait” discussion.

Fallible by design

The Result<()> return is intentional and mirrors the async GrpcClient::cancel_query. Explicit callers get to observe transport-level failures (network errors, channel closed, auth expired) so they can record metrics, retry, or surface “cancel failed” UX. This is not an impl Cancellable for GrpcClientSync — it cannot be, because Cancellable::cancel(&self) takes no arguments and has no way to pass the query_id. See the Cancellable trait docs for the infallible-wrapper pattern used by Drop-path consumers.

Example

use hyperdb_api_core::client::grpc::{GrpcClientSync, GrpcConfig};

client.cancel_query(query_id)?;

Errors

Same failure modes as GrpcClient::cancel_query — transport-level errors bubble up; a cancel for an already-completed query returns Ok(()) by design.

pub fn config(&self) -> &GrpcConfig

Returns the client configuration.

pub fn close(self) -> Result<(), Error>

Closes the connection (blocking).

Errors

Currently infallible — always returns Ok(()). The Result return type is preserved for API symmetry with async callers.

Trait Implementations

impl Debug for GrpcClientSync

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

Formats the value using the given formatter.