Struct BigQuerySessionStoreAdapter 

pub struct BigQuerySessionStoreAdapter { /* private fields */ }

Implementations

impl BigQuerySessionStoreAdapter

pub const DEFAULT_API_BASE_URL: &'static str = "https://bigquery.googleapis.com/bigquery/v2"

pub fn new( _legacy_bq_binary: impl AsRef<Path>, dataset: impl Into<String>, table: impl Into<String>, ) -> Self

pub fn new_native(dataset: impl Into<String>, table: impl Into<String>) -> Self

pub fn with_project_id(self, project_id: impl Into<String>) -> Self

pub fn with_api_base_url(self, api_base_url: impl Into<String>) -> Self

pub fn with_access_token(self, access_token: impl Into<String>) -> Self

pub fn with_http_timeout(self, timeout: Duration) -> Self

pub fn with_bearer_token(self, access_token: impl Into<String>) -> Self

pub fn table_ref(&self) -> String

pub async fn stream_insert_rows( &self, rows: &[SessionPersistenceRow], ) -> Result<(), BigQuerySessionStoreError>

pub async fn read_rows( &self, ) -> Result<Vec<SessionPersistenceRow>, BigQuerySessionStoreError>

pub async fn read_latest_rows( &self, ) -> Result<Vec<SessionPersistenceRow>, BigQuerySessionStoreError>

pub async fn read_live_rows( &self, ) -> Result<Vec<SessionPersistenceRow>, BigQuerySessionStoreError>

pub async fn gc_superseded_rows(&self) -> Result<u64, BigQuerySessionStoreError>

pub async fn truncate_sessions(&self) -> Result<(), BigQuerySessionStoreError>

Trait Implementations

impl Clone for BigQuerySessionStoreAdapter

fn clone(&self) -> BigQuerySessionStoreAdapter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BigQuerySessionStoreAdapter

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

Formats the value using the given formatter.