Struct AppendWithOffset 

pub struct AppendWithOffset { /* private fields */ }

A request builder for appending rows with a specific stream offset, ensuring exactly-once semantics.

Implementations

impl AppendWithOffset

pub fn set_offset(self, offset: i64) -> Self

Sets the target stream offset to guarantee exactly-once writes.

Example

let resp = writer.append(rows()).set_offset(0).send().await?;

use google_cloud_bigquery::model::ArrowRecordBatch;
fn rows() -> ArrowRecordBatch {
  todo!("Define your rows...")
}

pub fn send(self) -> AppendFuture

Append rows to the stream.

Applications are encouraged to queue up requests and await their responses independently.

Note that the service will reject requests with a mismatched offset, so requests must be queued in order.

Example

let f1 = writer.append(rows()).set_offset(0).send();
let f2 = writer.append(rows()).set_offset(1).send();

let resp1 = f1.await?;
let resp2 = f2.await?;

use google_cloud_bigquery::model::ArrowRecordBatch;
fn rows() -> ArrowRecordBatch {
  todo!("Define your rows...")
}

Trait Implementations

impl Clone for AppendWithOffset

fn clone(&self) -> AppendWithOffset

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AppendWithOffset

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.