Struct hypersync_client::Client

pub struct Client { /* private fields */ }

Implementations

impl Client

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

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

pub async fn collect_events( self: Arc<Self>, query: Query, config: StreamConfig ) -> Result<QueryResponse<Vec<Vec<Event>>>>

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

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

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

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

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

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

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

pub async fn stream_events( self: Arc<Self>, query: Query, config: StreamConfig ) -> Result<Receiver<Result<QueryResponse<Vec<Vec<Event>>>>>>

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

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

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

Performs copy-assignment from source.