Struct google_cloud_bigquery::grpc::apiv1::bigquery_client::StreamingWriteClient

pub struct StreamingWriteClient { /* private fields */ }

Implementations

impl StreamingWriteClient

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

pub async fn append_rows( &mut self, req: impl IntoStreamingRequest<Message = AppendRowsRequest> ) -> Result<Response<Streaming<AppendRowsResponse>>, Status>

pub async fn create_write_stream( &mut self, req: CreateWriteStreamRequest, retry: Option<RetrySetting> ) -> Result<Response<WriteStream>, Status>

pub async fn get_write_stream( &mut self, req: GetWriteStreamRequest, retry: Option<RetrySetting> ) -> Result<Response<WriteStream>, Status>

pub async fn finalize_write_stream( &mut self, req: FinalizeWriteStreamRequest, retry: Option<RetrySetting> ) -> Result<Response<FinalizeWriteStreamResponse>, Status>

pub async fn batch_commit_write_streams( &mut self, req: BatchCommitWriteStreamsRequest, retry: Option<RetrySetting> ) -> Result<Response<BatchCommitWriteStreamsResponse>, Status>

pub async fn flush_rows( &mut self, req: FlushRowsRequest, retry: Option<RetrySetting> ) -> Result<Response<FlushRowsResponse>, Status>

Trait Implementations

impl Clone for StreamingWriteClient

fn clone(&self) -> StreamingWriteClient

Returns a copy of the value.

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

Performs copy-assignment from source.