Struct googapis::google::firestore::v1beta1::firestore_client::FirestoreClient [−][src]
pub struct FirestoreClient<T> { /* fields omitted */ }
Expand description
The Cloud Firestore service.
Cloud Firestore is a fast, fully managed, serverless, cloud-native NoSQL document database that simplifies storing, syncing, and querying data for your mobile, web, and IoT apps at global scale. Its client libraries provide live synchronization and offline support, while its security features and integrations with Firebase and Google Cloud Platform (GCP) accelerate building truly serverless apps.
Implementations
impl<T> FirestoreClient<T> where
T: GrpcService<BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
impl<T> FirestoreClient<T> where
T: GrpcService<BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
pub fn with_interceptor<F>(
inner: T,
interceptor: F
) -> FirestoreClient<InterceptedService<T, F>> where
F: Interceptor,
T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>,
<T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,
Compress requests with gzip
.
This requires the server to support it otherwise it might respond with an error.
Enable decompressing responses with gzip
.
pub async fn get_document(
&mut self,
request: impl IntoRequest<GetDocumentRequest>
) -> Result<Response<Document>, Status>
pub async fn get_document(
&mut self,
request: impl IntoRequest<GetDocumentRequest>
) -> Result<Response<Document>, Status>
Gets a single document.
pub async fn list_documents(
&mut self,
request: impl IntoRequest<ListDocumentsRequest>
) -> Result<Response<ListDocumentsResponse>, Status>
pub async fn list_documents(
&mut self,
request: impl IntoRequest<ListDocumentsRequest>
) -> Result<Response<ListDocumentsResponse>, Status>
Lists documents.
pub async fn update_document(
&mut self,
request: impl IntoRequest<UpdateDocumentRequest>
) -> Result<Response<Document>, Status>
pub async fn update_document(
&mut self,
request: impl IntoRequest<UpdateDocumentRequest>
) -> Result<Response<Document>, Status>
Updates or inserts a document.
pub async fn delete_document(
&mut self,
request: impl IntoRequest<DeleteDocumentRequest>
) -> Result<Response<()>, Status>
pub async fn delete_document(
&mut self,
request: impl IntoRequest<DeleteDocumentRequest>
) -> Result<Response<()>, Status>
Deletes a document.
pub async fn batch_get_documents(
&mut self,
request: impl IntoRequest<BatchGetDocumentsRequest>
) -> Result<Response<Streaming<BatchGetDocumentsResponse>>, Status>
pub async fn batch_get_documents(
&mut self,
request: impl IntoRequest<BatchGetDocumentsRequest>
) -> Result<Response<Streaming<BatchGetDocumentsResponse>>, Status>
Gets multiple documents.
Documents returned by this method are not guaranteed to be returned in the same order that they were requested.
pub async fn begin_transaction(
&mut self,
request: impl IntoRequest<BeginTransactionRequest>
) -> Result<Response<BeginTransactionResponse>, Status>
pub async fn begin_transaction(
&mut self,
request: impl IntoRequest<BeginTransactionRequest>
) -> Result<Response<BeginTransactionResponse>, Status>
Starts a new transaction.
pub async fn commit(
&mut self,
request: impl IntoRequest<CommitRequest>
) -> Result<Response<CommitResponse>, Status>
pub async fn commit(
&mut self,
request: impl IntoRequest<CommitRequest>
) -> Result<Response<CommitResponse>, Status>
Commits a transaction, while optionally updating documents.
pub async fn rollback(
&mut self,
request: impl IntoRequest<RollbackRequest>
) -> Result<Response<()>, Status>
pub async fn rollback(
&mut self,
request: impl IntoRequest<RollbackRequest>
) -> Result<Response<()>, Status>
Rolls back a transaction.
pub async fn run_query(
&mut self,
request: impl IntoRequest<RunQueryRequest>
) -> Result<Response<Streaming<RunQueryResponse>>, Status>
pub async fn run_query(
&mut self,
request: impl IntoRequest<RunQueryRequest>
) -> Result<Response<Streaming<RunQueryResponse>>, Status>
Runs a query.
pub async fn partition_query(
&mut self,
request: impl IntoRequest<PartitionQueryRequest>
) -> Result<Response<PartitionQueryResponse>, Status>
pub async fn partition_query(
&mut self,
request: impl IntoRequest<PartitionQueryRequest>
) -> Result<Response<PartitionQueryResponse>, Status>
Partitions a query by returning partition cursors that can be used to run the query in parallel. The returned partition cursors are split points that can be used by RunQuery as starting/end points for the query results.
pub async fn write(
&mut self,
request: impl IntoStreamingRequest<Message = WriteRequest>
) -> Result<Response<Streaming<WriteResponse>>, Status>
pub async fn write(
&mut self,
request: impl IntoStreamingRequest<Message = WriteRequest>
) -> Result<Response<Streaming<WriteResponse>>, Status>
Streams batches of document updates and deletes, in order.
pub async fn listen(
&mut self,
request: impl IntoStreamingRequest<Message = ListenRequest>
) -> Result<Response<Streaming<ListenResponse>>, Status>
pub async fn listen(
&mut self,
request: impl IntoStreamingRequest<Message = ListenRequest>
) -> Result<Response<Streaming<ListenResponse>>, Status>
Listens to changes.
pub async fn list_collection_ids(
&mut self,
request: impl IntoRequest<ListCollectionIdsRequest>
) -> Result<Response<ListCollectionIdsResponse>, Status>
pub async fn list_collection_ids(
&mut self,
request: impl IntoRequest<ListCollectionIdsRequest>
) -> Result<Response<ListCollectionIdsResponse>, Status>
Lists all the collection IDs underneath a document.
pub async fn batch_write(
&mut self,
request: impl IntoRequest<BatchWriteRequest>
) -> Result<Response<BatchWriteResponse>, Status>
pub async fn batch_write(
&mut self,
request: impl IntoRequest<BatchWriteRequest>
) -> Result<Response<BatchWriteResponse>, Status>
Applies a batch of write operations.
The BatchWrite method does not apply the write operations atomically and can apply them out of order. Method does not allow more than one write per document. Each write succeeds or fails independently. See the [BatchWriteResponse][google.firestore.v1beta1.BatchWriteResponse] for the success status of each write.
If you require an atomically applied set of writes, use [Commit][google.firestore.v1beta1.Firestore.Commit] instead.
pub async fn create_document(
&mut self,
request: impl IntoRequest<CreateDocumentRequest>
) -> Result<Response<Document>, Status>
pub async fn create_document(
&mut self,
request: impl IntoRequest<CreateDocumentRequest>
) -> Result<Response<Document>, Status>
Creates a new document.
Trait Implementations
Auto Trait Implementations
impl<T> RefUnwindSafe for FirestoreClient<T> where
T: RefUnwindSafe,
impl<T> Send for FirestoreClient<T> where
T: Send,
impl<T> Sync for FirestoreClient<T> where
T: Sync,
impl<T> Unpin for FirestoreClient<T> where
T: Unpin,
impl<T> UnwindSafe for FirestoreClient<T> where
T: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Wrap the input message T
in a tonic::Request
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more