Struct StorageApi 

pub struct StorageApi { /* private fields */ }

High-level client for BigQuery Storage Write API operations.

Implementations

impl StorageApi

pub fn create_rows<M: Message>( table_descriptor: &TableDescriptor, rows: &[M], max_size_bytes: usize, ) -> (Rows, usize)

Encodes message rows into protobuf format with size management.

Processes as many rows as possible while respecting the specified size limit. Returns the encoded protobuf data and the count of rows successfully processed. When the returned count is less than the input slice length, additional calls are required for remaining rows.

The size limit should be below 10MB to accommodate request metadata overhead; 9MB provides a safe margin.

pub async fn get_write_stream( &mut self, stream_name: &StreamName, view: WriteStreamView, ) -> Result<WriteStream, BQError>

Retrieves metadata for a BigQuery write stream.

Fetches stream information including schema definition and state details according to the specified view level. Higher view levels provide more comprehensive information but may have higher latency.

pub async fn append_rows( &mut self, stream_name: &StreamName, rows: Rows, trace_id: String, ) -> Result<Streaming<AppendRowsResponse>, BQError>

Appends rows to a BigQuery table using the Storage Write API.

Transmits the provided rows to the specified stream and returns a streaming response for processing results. The trace ID enables request tracking across distributed systems for debugging.

pub async fn append_table_batches_concurrent<M>( &self, table_batches: Vec<TableBatch<M>>, max_concurrent_streams: usize, trace_id: &str, ) -> Result<Vec<BatchAppendResult>, BQError>

where M: Message + Send + 'static,

Appends rows from multiple table batches with concurrent processing.

Returns a collection of batch results containing responses, metadata, and bytes sent for each batch processed. Results are ordered by completion, not by submission; use BatchAppendResult::batch_index to correlate with the original input order.

Trait Implementations

impl Clone for StorageApi

fn clone(&self) -> StorageApi

Returns a duplicate of the value.

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

Performs copy-assignment from source.