[−][src]Struct gcp_client::google::bigtable::v1::bigtable_service_client::BigtableServiceClient
Service for reading from and writing to existing Bigtables.
Implementations
impl<T> BigtableServiceClient<T> where
T: GrpcService<BoxBody>,
T::ResponseBody: Body + HttpBody + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as HttpBody>::Error: Into<StdError> + Send,
[src]
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
[src]
pub fn with_interceptor(inner: T, interceptor: impl Into<Interceptor>) -> Self
[src]
pub async fn read_rows<'_>(
&'_ mut self,
request: impl IntoRequest<ReadRowsRequest>
) -> Result<Response<Streaming<ReadRowsResponse>>, Status>
[src]
&'_ mut self,
request: impl IntoRequest<ReadRowsRequest>
) -> Result<Response<Streaming<ReadRowsResponse>>, Status>
Streams back the contents of all requested rows, optionally applying the same Reader filter to each. Depending on their size, rows may be broken up across multiple responses, but atomicity of each row will still be preserved.
pub async fn sample_row_keys<'_>(
&'_ mut self,
request: impl IntoRequest<SampleRowKeysRequest>
) -> Result<Response<Streaming<SampleRowKeysResponse>>, Status>
[src]
&'_ 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<()>, Status>
[src]
&'_ mut self,
request: impl IntoRequest<MutateRowRequest>
) -> Result<Response<()>, 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<MutateRowsResponse>, Status>
[src]
&'_ mut self,
request: impl IntoRequest<MutateRowsRequest>
) -> Result<Response<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>
[src]
&'_ 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<Row>, Status>
[src]
&'_ mut self,
request: impl IntoRequest<ReadModifyWriteRowRequest>
) -> Result<Response<Row>, Status>
Modifies a row atomically, reading the latest existing timestamp/value from the specified columns and writing a new value at max(existing timestamp, current server time) based on pre-defined read/modify/write rules. Returns the new contents of all modified cells.
Trait Implementations
impl<T: Clone> Clone for BigtableServiceClient<T>
[src]
fn clone(&self) -> Self
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl<T> Debug for BigtableServiceClient<T>
[src]
Auto Trait Implementations
impl<T> !RefUnwindSafe for BigtableServiceClient<T>
impl<T> Send for BigtableServiceClient<T> where
T: Send,
T: Send,
impl<T> Sync for BigtableServiceClient<T> where
T: Sync,
T: Sync,
impl<T> Unpin for BigtableServiceClient<T> where
T: Unpin,
T: Unpin,
impl<T> !UnwindSafe for BigtableServiceClient<T>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> IntoRequest<T> for T
[src]
fn into_request(self) -> Request<T>
[src]
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,
fn vzip(self) -> V
impl<T> WithSubscriber for T
[src]
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,