Struct AsyncTesseraClient 

pub struct AsyncTesseraClient { /* private fields */ }

An async client for the Tessera API.

Mirror of crate::TesseraClient with async fn; use it inside tokio runtimes (including when the sync client would panic).

Implementations

impl AsyncTesseraClient

pub fn new(api_key: Option<&str>) -> Result<Self, TesseraError>

Create a client with defaults, resolving the key from api_key or $TESSERA_API_KEY.

Errors

Returns TesseraError::Configuration when no API key can be resolved.

pub fn from_config(config: ClientConfig) -> Result<Self, TesseraError>

Create a client from a fully-specified ClientConfig.

Errors

Returns TesseraError::Network when the HTTP client cannot be built.

pub fn config(&self) -> &ClientConfig

The resolved configuration this client was built with.

pub fn close(&mut self)

Close the client.

reqwest::Client tears its pool down on drop; taking the client out eagerly releases the handle for parity with the Python aclose().

pub async fn datasets(&self) -> Result<DatasetsResponse, TesseraError>

List every dataset visible to your plan.

Errors

Returns any TesseraError the API or transport raises.

pub async fn partitions( &self, asset: &str, coin: Option<&str>, month: Option<&str>, ) -> Result<PartitionsResponse, TesseraError>

List the partitions of asset, optionally filtered by coin/month.

Errors

Returns any TesseraError the API or transport raises.

pub async fn download_url( &self, asset: &str, coin: &str, month: &str, ) -> Result<DownloadResponse, TesseraError>

Mint a short-lived presigned download URL for one partition.

Errors

Returns any TesseraError the API or transport raises.

pub fn partition_refs( &self, asset: &str, coin: impl IntoCoins, month: impl IntoMonths, ) -> Result<Vec<PartitionRef>, TesseraError>

Expand (asset, coins, months) into concrete partition references.

Errors

Returns TesseraError::InvalidArgument on empty/invalid arguments.

pub async fn scan( &self, asset: &str, coin: impl IntoCoins, month: impl IntoMonths, columns: Option<&[&str]>, ) -> Result<LazyFrame, TesseraError>

Lazily scan one or more partitions into a Polars LazyFrame.

Errors

Returns any TesseraError the API or transport raises.

pub async fn read( &self, asset: &str, coin: impl IntoCoins, month: impl IntoMonths, columns: Option<&[&str]>, ) -> Result<DataFrame, TesseraError>

Eagerly read one or more partitions into a Polars DataFrame.

Errors

Returns any TesseraError the API or transport raises, including TesseraError::PresignExpired for rejected presigned URLs.

pub async fn to_duckdb( &self, asset: &str, coin: impl IntoCoins, month: impl IntoMonths, columns: Option<&[&str]>, ) -> Result<Connection, TesseraError>

Open one or more partitions as an in-memory DuckDB connection exposing a tessera view for SQL querying.

Errors

Returns any TesseraError the API or transport raises.

Trait Implementations

impl Debug for AsyncTesseraClient

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

Formats the value using the given formatter.