Struct google_cloud_bigquery::grpc::apiv1::bigquery_client::StreamingReadClient

pub struct StreamingReadClient { /* private fields */ }

Implementations

impl StreamingReadClient

pub fn new(inner: BigQueryReadClient<Channel>) -> Self

pub async fn create_read_session( &mut self, req: CreateReadSessionRequest, retry: Option<RetrySetting> ) -> Result<Response<ReadSession>, Status>

pub async fn read_rows( &mut self, req: ReadRowsRequest, retry: Option<RetrySetting> ) -> Result<Response<Streaming<ReadRowsResponse>>, Status>

pub async fn split_read_stream( &mut self, req: SplitReadStreamRequest, retry: Option<RetrySetting> ) -> Result<Response<SplitReadStreamResponse>, Status>