Struct Client 

pub struct Client { /* private fields */ }

Blocking DataPress client.

Each instance owns a single-threaded Tokio runtime used to drive the async client to completion. Not Clone (the runtime is not shared); create one per thread.

Implementations

impl Client

pub fn new(base_url: impl Into<String>) -> Result<Self>

Construct a blocking client with defaults for base_url.

pub fn from_async(inner: Client) -> Result<Self>

Wrap an already-built async crate::Client.

pub fn builder(base_url: impl Into<String>) -> ClientBuilder

Start a crate::ClientBuilder; pass the result to Client::from_async after .build().

pub fn healthz(&self) -> Result<JsonValue>

Liveness probe.

pub fn readyz(&self) -> Result<JsonValue>

Readiness probe.

pub fn datasets(&self) -> Result<Vec<String>>

List registered dataset names.

pub fn schema(&self, dataset: &str) -> Result<JsonValue>

Fetch the schema description for dataset.

pub fn count(&self, dataset: &str, predicates: &[Predicate]) -> Result<u64>

Count matching rows.

pub fn query_json( &self, dataset: &str, request: &QueryRequest, ) -> Result<QueryResponse>

Run a structured query, returning the JSON envelope.

pub fn sql( &self, sql: impl Into<String>, max_rows: Option<u64>, ) -> Result<SqlResponse>

Run a raw read-only SQL statement.

pub fn reload(&self, dataset: &str) -> Result<JsonValue>

Trigger an in-place reload of dataset.

pub fn query_arrow_bytes( &self, dataset: &str, request: &QueryRequest, ) -> Result<Bytes>

Run a structured query asking for Arrow IPC, returning the raw stream bytes.

pub fn query_arrow( &self, dataset: &str, request: &QueryRequest, ) -> Result<Vec<RecordBatch>>

Run a structured query and decode the Arrow IPC response into record batches.

pub fn inner(&self) -> &Client

Access the underlying async client (shares the same HTTP pool).