Struct gapi_grpc::google::bigtable::v2::bigtable_client::BigtableClient

pub struct BigtableClient<T> { /* fields omitted */ }

Service for reading from and writing to existing Bigtable tables.

Implementations

impl BigtableClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error> where
    D: TryInto<Endpoint>,
    D::Error: Into<StdError>, 

Attempt to create a new client by connecting to a given endpoint.

impl<T> BigtableClient<T> where
    T: GrpcService<BoxBody>,
    T::ResponseBody: Body + HttpBody + Send + 'static,
    T::Error: Into<StdError>,
    <T::ResponseBody as HttpBody>::Error: Into<StdError> + Send, 

pub fn new(inner: T) -> Self

pub fn with_interceptor(inner: T, interceptor: impl Into<Interceptor>) -> Self

pub async fn read_rows(
    &mut self,
    request: impl IntoRequest<ReadRowsRequest>
) -> Result<Response<Streaming<ReadRowsResponse>>, Status>

Streams back the contents of all requested rows in key order, optionally applying the same Reader filter to each. Depending on their size, rows and cells may be broken up across multiple responses, but atomicity of each row will still be preserved. See the ReadRowsResponse documentation for details.

pub async fn sample_row_keys(
    &mut self,
    request: impl IntoRequest<SampleRowKeysRequest>
) -> Result<Response<Streaming<SampleRowKeysResponse>>, Status>

Returns a sample of row keys in the table. The returned row keys will delimit contiguous sections of the table of approximately equal size, which can be used to break up the data for distributed tasks like mapreduces.

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

Mutates a row atomically. Cells already present in the row are left unchanged unless explicitly changed by mutation.

pub async fn mutate_rows(
    &mut self,
    request: impl IntoRequest<MutateRowsRequest>
) -> Result<Response<Streaming<MutateRowsResponse>>, Status>

Mutates multiple rows in a batch. Each individual row is mutated atomically as in MutateRow, but the entire batch is not executed atomically.

pub async fn check_and_mutate_row(
    &mut self,
    request: impl IntoRequest<CheckAndMutateRowRequest>
) -> Result<Response<CheckAndMutateRowResponse>, Status>

Mutates a row atomically based on the output of a predicate Reader filter.

pub async fn read_modify_write_row(
    &mut self,
    request: impl IntoRequest<ReadModifyWriteRowRequest>
) -> Result<Response<ReadModifyWriteRowResponse>, Status>

Modifies a row atomically on the server. The method reads the latest existing timestamp and value from the specified columns and writes a new entry based on pre-defined read/modify/write rules. The new value for the timestamp is the greater of the existing timestamp or the current server time. The method returns the new contents of all modified cells.

Trait Implementations

impl<T: Clone> Clone for BigtableClient<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Debug for BigtableClient<T>

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

Formats the value using the given formatter.