Struct Client 

pub struct Client { /* private fields */ }

Asynchronous client for a running DataPress server.

Cheap to clone (wraps an Arc internally via reqwest::Client); share one instance across tasks.

Implementations

impl Client

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

Construct a client with defaults for base_url.

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

Start a ClientBuilder.

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

Liveness probe — GET /healthz (always at the host root).

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

Readiness probe — GET /readyz. Returns a 503 error while the server is still loading datasets.

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

List registered dataset names.

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

Fetch the schema description for dataset.

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

Count matching rows. predicates is the same predicate shape used by QueryRequest; None/empty = unfiltered.

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

Run a structured query and return the decoded JSON envelope.

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

Run a raw read-only SQL statement (POST /sql). The endpoint must be enabled server-side ([sql].enabled = true), else a 404 is returned.

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

Trigger an in-place reload of dataset (requires admin_token or the configured reload scopes).

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

Run a structured query against the Arrow IPC streaming endpoint (POST /datasets/{name}/query/stream), returning the raw IPC stream bytes. Use Client::query_arrow to decode them into record batches.

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

Run a structured query and decode the Arrow IPC response into a vector of arrow::record_batch::RecordBatch.

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Client

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

Formats the value using the given formatter.