public class GrpcFirestoreRpc implements FirestoreRpc
GRPC client implementation of the Firestore RPC methods. Exposes FirestoreOptions on top of the
GRPC-based Firestore GAPIC client.
Constructors
GrpcFirestoreRpc(FirestoreOptions options)
public GrpcFirestoreRpc(FirestoreOptions options)
Methods
batchGetDocumentsCallable()
public ServerStreamingCallable<BatchGetDocumentsRequest,BatchGetDocumentsResponse> batchGetDocumentsCallable()
batchWriteCallable()
public UnaryCallable<BatchWriteRequest,BatchWriteResponse> batchWriteCallable()
beginTransactionCallable()
public UnaryCallable<BeginTransactionRequest,BeginTransactionResponse> beginTransactionCallable()
Starts a new transaction.
close()
commitCallable()
public UnaryCallable<CommitRequest,CommitResponse> commitCallable()
Commits a transaction, while optionally updating documents.
getExecutor()
public ScheduledExecutorService getExecutor()
Returns the executor used by the GAPIC client.
listCollectionIdsPagedCallable()
public UnaryCallable<ListCollectionIdsRequest,FirestoreClient.ListCollectionIdsPagedResponse> listCollectionIdsPagedCallable()
Returns a list of collections IDs.
listDocumentsPagedCallable()
public UnaryCallable<ListDocumentsRequest,FirestoreClient.ListDocumentsPagedResponse> listDocumentsPagedCallable()
Returns a list of documents.
listenCallable()
public BidiStreamingCallable<ListenRequest,ListenResponse> listenCallable()
Returns a bi-directional watch stream.
partitionQueryPagedCallable()
public UnaryCallable<PartitionQueryRequest,FirestoreClient.PartitionQueryPagedResponse> partitionQueryPagedCallable()
rollbackCallable()
public UnaryCallable<RollbackRequest,Empty> rollbackCallable()
Rolls back a transaction.
runAggregationQueryCallable()
public ServerStreamingCallable<RunAggregationQueryRequest,RunAggregationQueryResponse> runAggregationQueryCallable()
Runs an aggregation query.
runQueryCallable()
public ServerStreamingCallable<RunQueryRequest,RunQueryResponse> runQueryCallable()
shutdown()
shutdownNow()
public void shutdownNow()