Struct parpulse_client::client::StorageClientImpl

pub struct StorageClientImpl { /* private fields */ }

Implementations

impl StorageClientImpl

pub fn new( storage_server_endpoint_str: &str, catalog_server_endpoint_str: &str ) -> Result<Self>

pub async fn request_data_test( &self, request: StorageRequest ) -> Result<Receiver<RecordBatch>>

Trait Implementations

impl StorageClient for StorageClientImpl

fn request_data<'life0, 'async_trait>( &'life0 self, request: StorageRequest ) -> Pin<Box<dyn Future<Output = Result<Receiver<RecordBatch>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the requested data as a stream.

fn request_data_sync<'life0, 'async_trait>( &'life0 self, _request: StorageRequest ) -> Pin<Box<dyn Future<Output = Result<Vec<RecordBatch>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns all the requested data as a whole.