Struct Client 

pub struct Client { /* private fields */ }

Internal client to handle http requests and retries.

Implementations

impl Client

pub fn new(cfg: ClientConfig) -> Result<Self>

Creates a new client with the given configuration.

pub async fn collect_arrow( self: Arc<Self>, query: Query, config: StreamConfig, ) -> Result<ArrowResponse>

Retrieves blocks, transactions, traces, and logs in Arrow format through a stream using the provided query and stream configuration.

pub async fn collect_parquet( self: Arc<Self>, path: &str, query: Query, config: StreamConfig, ) -> Result<()>

Writes parquet file getting data through a stream using the provided path, query, and stream configuration.

pub async fn get_chain_id(&self) -> Result<u64>

Get the chain_id from the server with retries.

pub async fn get_height(&self) -> Result<u64>

Get the height of from server with retries.

pub async fn health_check( &self, http_req_timeout: Option<Duration>, ) -> Result<u64>

Get the height of the Client instance for health checks. Doesn’t do any retries and the http_req_timeout parameter will override the http timeout config set when creating the client.

pub async fn get(&self, query: &Query) -> Result<QueryResponse>

Executes query with retries and returns the response.

pub async fn get_arrow(&self, query: &Query) -> Result<ArrowResponse>

Executes query with retries and returns the response in Arrow format.

pub async fn stream_arrow( self: Arc<Self>, query: Query, config: StreamConfig, ) -> Result<Receiver<Result<ArrowResponse>>>

Spawns task to execute query and return data via a channel in Arrow format.

pub fn url(&self) -> &Url

Getter for url field.

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.