Struct google_cloud_spanner::transaction::QueryOptions

pub struct QueryOptions {
    pub mode: QueryMode,
    pub optimizer_options: Option<ExecuteQueryOptions>,
    pub call_options: CallOptions,
    pub enable_resume: bool,
}

Fields

mode: QueryMode

optimizer_options: Option<ExecuteQueryOptions>

call_options: CallOptions

enable_resume: bool

If cancel safe is required, such as when tokio::select is used, set to false.

use time::{Duration, OffsetDateTime};
use google_cloud_spanner::reader::AsyncIterator;
use google_cloud_spanner::client::Client;
use google_cloud_spanner::key::Key;
use google_cloud_spanner::statement::Statement;
use google_cloud_spanner::transaction::QueryOptions;

async fn query(client: Client) {
  let mut tx = client.single().await.unwrap();
  let option = QueryOptions {
    enable_resume: false,
    ..Default::default()
  };
  let mut stmt = Statement::new("SELECT ChangeRecord FROM READ_UserItemChangeStream (
          start_timestamp => @now,
          end_timestamp => NULL,
          partition_token => {},
          heartbeat_milliseconds => 10000
  )");
  stmt.add_param("now", &OffsetDateTime::now_utc());
  let mut rows = tx.query_with_option(stmt, option).await.unwrap();
  let mut tick = tokio::time::interval(tokio::time::Duration::from_millis(100));
  loop {
    tokio::select! {
       _ = tick.tick() => {
            // run task
       },
       maybe = rows.next() =>  {
         let row = maybe.unwrap().unwrap();
       }
    }
  }
}

Trait Implementations

impl Clone for QueryOptions

fn clone(&self) -> QueryOptions

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for QueryOptions

fn default() -> Self

Returns the “default value” for a type.