Struct bigtable_rs::bigtable::BigTable

pub struct BigTable { /* private fields */ }

The core struct for Bigtable client, which wraps a gPRC client defined by Bigtable proto. In order to easily use this struct in multiple threads, we only store cloneable references here. BigtableClient<AuthSvc> is a type alias of BigtableClient and it wraps a tonic Channel. Cloning on Bigtable is cheap.

Bigtable can be created via bigtable::BigTableConnection::new() and cloned

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
  use bigtable_rs::bigtable;
  let connection = bigtable::BigTableConnection::new("p-id", "i-id", true, 1, None).await?;
  let bt_client = connection.client();
  // Cheap to clone clients and used in other places.
  let bt_client2 = bt_client.clone();
  Ok(())
}

Implementations

impl BigTable

pub async fn check_and_mutate_row( &mut self, request: CheckAndMutateRowRequest ) -> Result<CheckAndMutateRowResponse, Error>

Wrapped check_and_mutate_row method

pub async fn read_rows( &mut self, request: ReadRowsRequest ) -> Result<Vec<(Vec<u8>, Vec<RowCell>)>, Error>

Wrapped read_rows method

pub async fn read_rows_with_prefix( &mut self, request: ReadRowsRequest, prefix: Vec<u8> ) -> Result<Vec<(Vec<u8>, Vec<RowCell>)>, Error>

Provide read_rows_with_prefix method to allow using a prefix as key

pub async fn sample_row_keys( &mut self, request: SampleRowKeysRequest ) -> Result<Streaming<SampleRowKeysResponse>, Error>

Wrapped sample_row_keys method

pub async fn mutate_row( &mut self, request: MutateRowRequest ) -> Result<Response<MutateRowResponse>, Error>

Wrapped mutate_row method

pub async fn mutate_rows( &mut self, request: MutateRowsRequest ) -> Result<Streaming<MutateRowsResponse>, Error>

Wrapped mutate_rows method

pub fn get_client(&mut self) -> &mut BigtableClient<AuthSvc>

Provide a convenient method to get the inner BigtableClient so user can use any methods defined from the Bigtable V2 gRPC API

pub fn get_full_table_name(&self, table_name: &str) -> String

Provide a convenient method to get full table, which can be used for building requests

Trait Implementations

impl Clone for BigTable

fn clone(&self) -> BigTable

Returns a copy of the value.

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

Performs copy-assignment from source.