[−][src]Struct firestore_grpc_cloudrun::firestore_client::FirestoreClient
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.
Methods
impl FirestoreClient<Channel>
[src]
pub async fn connect<D>(dst: D) -> Result<FirestoreClient<Channel>, Error> where
D: TryInto<Endpoint>,
<D as TryInto<Endpoint>>::Error: Into<Box<dyn Error + 'static + Sync + Send>>,
[src]
D: TryInto<Endpoint>,
<D as TryInto<Endpoint>>::Error: Into<Box<dyn Error + 'static + Sync + Send>>,
Attempt to create a new client by connecting to a given endpoint.
impl<T> FirestoreClient<T> where
T: GrpcService<BoxBody>,
<T as GrpcService<BoxBody>>::ResponseBody: Body,
<T as GrpcService<BoxBody>>::ResponseBody: Body,
<T as GrpcService<BoxBody>>::ResponseBody: Send,
<T as GrpcService<BoxBody>>::ResponseBody: 'static,
<T as GrpcService<BoxBody>>::Error: Into<Box<dyn Error + 'static + Sync + Send>>,
<<T as GrpcService<BoxBody>>::ResponseBody as Body>::Error: Into<Box<dyn Error + 'static + Sync + Send>>,
<<T as GrpcService<BoxBody>>::ResponseBody as Body>::Error: Send,
[src]
T: GrpcService<BoxBody>,
<T as GrpcService<BoxBody>>::ResponseBody: Body,
<T as GrpcService<BoxBody>>::ResponseBody: Body,
<T as GrpcService<BoxBody>>::ResponseBody: Send,
<T as GrpcService<BoxBody>>::ResponseBody: 'static,
<T as GrpcService<BoxBody>>::Error: Into<Box<dyn Error + 'static + Sync + Send>>,
<<T as GrpcService<BoxBody>>::ResponseBody as Body>::Error: Into<Box<dyn Error + 'static + Sync + Send>>,
<<T as GrpcService<BoxBody>>::ResponseBody as Body>::Error: Send,
pub fn new(inner: T) -> FirestoreClient<T>
[src]
pub fn with_interceptor(
inner: T,
interceptor: impl Into<Interceptor>
) -> FirestoreClient<T>
[src]
inner: T,
interceptor: impl Into<Interceptor>
) -> FirestoreClient<T>
pub async fn get_document(
&'_ mut self,
request: impl IntoRequest<GetDocumentRequest>
) -> Result<Response<Document>, Status>
[src]
&'_ 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>
[src]
&'_ 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>
[src]
&'_ 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>
[src]
&'_ 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>
[src]
&'_ 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>
[src]
&'_ 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>
[src]
&'_ 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>
[src]
&'_ 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>
[src]
&'_ mut self,
request: impl IntoRequest<RunQueryRequest>
) -> Result<Response<Streaming<RunQueryResponse>>, Status>
Runs a query.
pub async fn write(
&'_ mut self,
request: impl IntoStreamingRequest<Message = WriteRequest>
) -> Result<Response<Streaming<WriteResponse>>, Status>
[src]
&'_ 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>
[src]
&'_ 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>
[src]
&'_ mut self,
request: impl IntoRequest<ListCollectionIdsRequest>
) -> Result<Response<ListCollectionIdsResponse>, Status>
Lists all the collection IDs underneath a document.
pub async fn create_document(
&'_ mut self,
request: impl IntoRequest<CreateDocumentRequest>
) -> Result<Response<Document>, Status>
[src]
&'_ mut self,
request: impl IntoRequest<CreateDocumentRequest>
) -> Result<Response<Document>, Status>
Creates a new document.
Trait Implementations
impl<T> Clone for FirestoreClient<T> where
T: Clone,
[src]
T: Clone,
fn clone(&self) -> FirestoreClient<T>
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
Auto Trait Implementations
impl<T> !RefUnwindSafe for FirestoreClient<T>
impl<T> Send for FirestoreClient<T> where
T: Send,
T: Send,
impl<T> Sync for FirestoreClient<T> where
T: Sync,
T: Sync,
impl<T> Unpin for FirestoreClient<T> where
T: Unpin,
T: Unpin,
impl<T> !UnwindSafe for FirestoreClient<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>,
[src]
V: MultiLane<T>,
impl<T> WithSubscriber for T
[src]
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,