AsyncDocumentClient Interface
public interface AsyncDocumentClient
Provides a client-side logical representation of the Azure Cosmos DB database service. This async client is used to configure and execute requests against the service.
AsyncDocumentClient async APIs return rxJava'sObservable
</code> , and so you can use rxJava <xref uid="" data-throw-if-not-resolved="false" data-raw-source="Observable"></xref> functionality. <b>The async <xref uid="" data-throw-if-not-resolved="false" data-raw-source="Observable"></xref> based APIs perform the requested operation only after subscription.</b></p>
The service client encapsulates the endpoint and credentials used to access the Cosmos DB service.
To instantiate you can use the AsyncDocumentClient.Builder
ConnectionPolicy connectionPolicy = new ConnectionPolicy();
connectionPolicy.setConnectionMode(ConnectionMode.Direct);
AsyncDocumentClient client = new AsyncDocumentClient.Builder()
.withServiceEndpoint(serviceEndpoint)
.withMasterKeyOrResourceToken(masterKey)
.withConnectionPolicy(connectionPolicy)
.withConsistencyLevel(ConsistencyLevel.Session)
.build();
</code></pre></p>
Method Summary
Modifier and Type | Method and Description |
---|---|
void |
close()
Close this AsyncDocumentClient instance and cleans up the resources. |
Observable<Resource |
createAttachment(String documentLink, Attachment attachment, RequestOptions options)
Creates an attachment. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created attachment. In case of failure the Observable will error. |
Observable<Resource |
createAttachment(String documentLink, InputStream mediaStream, MediaOptions options, RequestOptions requestOptions)
Creates an attachment. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created attachment. In case of failure the Observable will error. |
Observable<Resource |
createCollection(String databaseLink, DocumentCollection collection, RequestOptions options)
Creates a document collection. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created collection. In case of failure the Observable will error. |
Observable<Resource |
createDatabase(Database database, RequestOptions options)
Creates a database. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created database. In case of failure the Observable will error. |
Observable<Resource |
createDocument(String collectionLink, Object document, RequestOptions options, boolean disableAutomaticIdGeneration)
Creates a document. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created document. In case of failure the Observable will error. |
Observable<Resource |
createPermission(String userLink, Permission permission, RequestOptions options)
Creates a permission. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created permission. In case of failure the Observable will error. |
Observable<Resource |
createStoredProcedure(String collectionLink, StoredProcedure storedProcedure, RequestOptions options)
Creates a stored procedure. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created stored procedure. In case of failure the Observable will error. |
Observable<Resource |
createTrigger(String collectionLink, Trigger trigger, RequestOptions options)
Creates a trigger. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created trigger. In case of failure the Observable will error. |
Observable<Resource |
createUser(String databaseLink, User user, RequestOptions options)
Creates a user. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created user. In case of failure the Observable will error. |
Observable<Resource |
createUserDefinedFunction(String collectionLink, UserDefinedFunction udf, RequestOptions options)
Creates a user defined function. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created user defined function. In case of failure the Observable will error. |
Observable<Resource |
deleteAttachment(String attachmentLink, RequestOptions options)
Deletes an attachment. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted attachment. In case of failure the Observable will error. |
Observable<Resource |
deleteCollection(String collectionLink, RequestOptions options)
Deletes a document collection by the collection link. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted database. In case of failure the Observable will error. |
Observable<Resource |
deleteConflict(String conflictLink, RequestOptions options)
Deletes a conflict. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted conflict. In case of failure the Observable will error. |
Observable<Resource |
deleteDatabase(String databaseLink, RequestOptions options)
Deletes a database. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the deleted database. In case of failure the Observable will error. |
Observable<Resource |
deleteDocument(String documentLink, RequestOptions options)
Deletes a document by the document link. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted document. In case of failure the Observable will error. |
Observable<Resource |
deletePermission(String permissionLink, RequestOptions options)
Deletes a permission. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted permission. In case of failure the Observable will error. |
Observable<Resource |
deleteStoredProcedure(String storedProcedureLink, RequestOptions options)
Deletes a stored procedure by the stored procedure link. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted stored procedure. In case of failure the Observable will error. |
Observable<Resource |
deleteTrigger(String triggerLink, RequestOptions options)
Deletes a trigger. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted trigger. In case of failure the Observable will error. |
Observable<Resource |
deleteUser(String userLink, RequestOptions options)
Deletes a user. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted user. In case of failure the Observable will error. |
Observable<Resource |
deleteUserDefinedFunction(String udfLink, RequestOptions options)
Deletes a user defined function. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted user defined function. In case of failure the Observable will error. |
Observable<Stored |
executeStoredProcedure(String storedProcedureLink, Object[] procedureParams)
Executes a stored procedure by the stored procedure link. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the stored procedure response. In case of failure the Observable will error. |
Observable<Stored |
executeStoredProcedure(String storedProcedureLink, RequestOptions options, Object[] procedureParams)
Executes a stored procedure by the stored procedure link. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the stored procedure response. In case of failure the Observable will error. |
Connection |
getConnectionPolicy()
Gets the connection policy |
Observable<Database |
getDatabaseAccount()
Gets database account information. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the database account. In case of failure the Observable will error. |
URI |
getReadEndpoint()
Gets the current read endpoint chosen based on availability and preference. |
URI |
getServiceEndpoint()
Gets the default service endpoint as passed in by the user during construction. |
URI |
getWriteEndpoint()
Gets the current write endpoint chosen based on availability and preference. |
void |
monitor(MeterRegistry registry)
Adds a meter registry for reporting Direct TCP metrics |
Observable<Feed |
queryAttachments(String documentLink, SqlQuerySpec querySpec, FeedOptions options)
Query for attachments. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained attachments. In case of failure the Observable will error. |
Observable<Feed |
queryAttachments(String documentLink, String query, FeedOptions options)
Query for attachments. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained attachments. In case of failure the Observable will error. |
Observable<Feed |
queryCollections(String databaseLink, SqlQuerySpec querySpec, FeedOptions options)
Query for document collections in a database. After subscription the operation will be performed. The Observable will contain one or several feed response of the obtained collections. In case of failure the Observable will error. |
Observable<Feed |
queryCollections(String databaseLink, String query, FeedOptions options)
Query for document collections in a database. After subscription the operation will be performed. The Observable will contain one or several feed response of the obtained collections. In case of failure the Observable will error. |
Observable<Feed |
queryConflicts(String collectionLink, SqlQuerySpec querySpec, FeedOptions options)
Query for conflicts. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained conflicts. In case of failure the Observable will error. |
Observable<Feed |
queryConflicts(String collectionLink, String query, FeedOptions options)
Query for conflicts. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained conflicts. In case of failure the Observable will error. |
Observable<Feed |
queryDatabases(SqlQuerySpec querySpec, FeedOptions options)
Query for databases. After subscription the operation will be performed. The Observable will contain one or several feed response of the obtained databases. In case of failure the Observable will error. |
Observable<Feed |
queryDatabases(String query, FeedOptions options)
Query for databases. After subscription the operation will be performed. The Observable will contain one or several feed response of the read databases. In case of failure the Observable will error. |
Observable<Feed |
queryDocumentChangeFeed(String collectionLink, ChangeFeedOptions changeFeedOptions)
Query for documents change feed in a document collection. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained documents. In case of failure the Observable will error. |
Observable<Feed |
queryDocuments(String collectionLink, SqlQuerySpec querySpec, FeedOptions options)
Query for documents in a document collection. After subscription the operation will be performed. The Observable will contain one or several feed response of the obtained documents. In case of failure the Observable will error. |
Observable<Feed |
queryDocuments(String collectionLink, String query, FeedOptions options)
Query for documents in a document collection. After subscription the operation will be performed. The Observable will contain one or several feed response of the obtained documents. In case of failure the Observable will error. |
Observable<Feed |
queryOffers(SqlQuerySpec querySpec, FeedOptions options)
Query for offers in a database. After subscription the operation will be performed. The Observable will contain one or several feed response pages of obtained obtained offers. In case of failure the Observable will error. |
Observable<Feed |
queryOffers(String query, FeedOptions options)
Query for offers in a database. After subscription the operation will be performed. The Observable will contain one or several feed response pages of obtained obtained offers. In case of failure the Observable will error. |
Observable<Feed |
queryPermissions(String permissionLink, SqlQuerySpec querySpec, FeedOptions options)
Query for permissions. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained permissions. In case of failure the Observable will error. |
Observable<Feed |
queryPermissions(String permissionLink, String query, FeedOptions options)
Query for permissions. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained permissions. In case of failure the Observable will error. |
Observable<Feed |
queryStoredProcedures(String collectionLink, SqlQuerySpec querySpec, FeedOptions options)
Query for stored procedures in a document collection. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained stored procedures. In case of failure the Observable will error. |
Observable<Feed |
queryStoredProcedures(String collectionLink, String query, FeedOptions options)
Query for stored procedures in a document collection. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained stored procedures. In case of failure the Observable will error. |
Observable<Feed |
queryTriggers(String collectionLink, SqlQuerySpec querySpec, FeedOptions options)
Query for triggers. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained triggers. In case of failure the Observable will error. |
Observable<Feed |
queryTriggers(String collectionLink, String query, FeedOptions options)
Query for triggers. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained triggers. In case of failure the Observable will error. |
Observable<Feed |
queryUserDefinedFunctions(String collectionLink, SqlQuerySpec querySpec, FeedOptions options)
Query for user defined functions. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained user defined functions. In case of failure the Observable will error. |
Observable<Feed |
queryUserDefinedFunctions(String collectionLink, String query, FeedOptions options)
Query for user defined functions. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained user defined functions. In case of failure the Observable will error. |
Observable<Feed |
queryUsers(String databaseLink, SqlQuerySpec querySpec, FeedOptions options)
Query for users. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained users. In case of failure the Observable will error. |
Observable<Feed |
queryUsers(String databaseLink, String query, FeedOptions options)
Query for users. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained users. In case of failure the Observable will error. |
Observable<Resource |
readAttachment(String attachmentLink, RequestOptions options)
Reads an attachment. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read attachment. In case of failure the Observable will error. |
Observable<Feed |
readAttachments(String documentLink, FeedOptions options)
Reads all attachments in a document. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read attachments. In case of failure the Observable will error. |
Observable<Resource |
readCollection(String collectionLink, RequestOptions options)
Reads a document collection by the collection link. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read collection. In case of failure the Observable will error. |
Observable<Feed |
readCollections(String databaseLink, FeedOptions options)
Reads all document collections in a database. After subscription the operation will be performed. The Observable will contain one or several feed response of the read collections. In case of failure the Observable will error. |
Observable<Resource |
readConflict(String conflictLink, RequestOptions options)
Reads a conflict. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read conflict. In case of failure the Observable will error. |
Observable<Feed |
readConflicts(String collectionLink, FeedOptions options)
Reads all conflicts in a document collection. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read conflicts. In case of failure the Observable will error. |
Observable<Resource |
readDatabase(String databaseLink, RequestOptions options)
Reads a database. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read database. In case of failure the Observable will error. |
Observable<Feed |
readDatabases(FeedOptions options)
Reads all databases. After subscription the operation will be performed. The Observable will contain one or several feed response of the read databases. In case of failure the Observable will error. |
Observable<Resource |
readDocument(String documentLink, RequestOptions options)
Reads a document by the document link. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read document. In case of failure the Observable will error. |
Observable<Feed |
readDocuments(String collectionLink, FeedOptions options)
Reads all documents in a document collection. After subscription the operation will be performed. The Observable will contain one or several feed response of the read documents. In case of failure the Observable will error. |
Observable<Media |
readMedia(String mediaLink)
Reads a media by the media link. |
Observable<Resource |
readOffer(String offerLink)
Reads an offer. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read offer. In case of failure the Observable will error. |
Observable<Feed |
readOffers(FeedOptions options)
Reads offers. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read offers. In case of failure the Observable will error. |
Observable<Feed |
readPartitionKeyRanges(String collectionLink, FeedOptions options)
Reads all partition key ranges in a document collection. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained partition key ranges. In case of failure the Observable will error. |
Observable<Resource |
readPermission(String permissionLink, RequestOptions options)
Reads a permission. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read permission. In case of failure the Observable will error. |
Observable<Feed |
readPermissions(String permissionLink, FeedOptions options)
Reads all permissions. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read permissions. In case of failure the Observable will error. |
Observable<Resource |
readStoredProcedure(String storedProcedureLink, RequestOptions options)
Read a stored procedure by the stored procedure link. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read stored procedure. In case of failure the Observable will error. |
Observable<Feed |
readStoredProcedures(String collectionLink, FeedOptions options)
Reads all stored procedures in a document collection link. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read stored procedures. In case of failure the Observable will error. |
Observable<Resource |
readTrigger(String triggerLink, RequestOptions options)
Reads a trigger by the trigger link. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the read trigger. In case of failure the Observable will error. |
Observable<Feed |
readTriggers(String collectionLink, FeedOptions options)
Reads all triggers in a document collection. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read triggers. In case of failure the Observable will error. |
Observable<Resource |
readUser(String userLink, RequestOptions options)
Reads a user. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read user. In case of failure the Observable will error. |
Observable<Resource |
readUserDefinedFunction(String udfLink, RequestOptions options)
Read a user defined function. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the read user defined function. In case of failure the Observable will error. |
Observable<Feed |
readUserDefinedFunctions(String collectionLink, FeedOptions options)
Reads all user defined functions in a document collection. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read user defined functions. In case of failure the Observable will error. |
Observable<Feed |
readUsers(String databaseLink, FeedOptions options)
Reads all users in a database. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read users. In case of failure the Observable will error. |
Observable<Resource |
replaceAttachment(Attachment attachment, RequestOptions options)
Replaces an attachment. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced attachment. In case of failure the Observable will error. |
Observable<Resource |
replaceCollection(DocumentCollection collection, RequestOptions options)
Replaces a document collection. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced document collection. In case of failure the Observable will error. |
Observable<Resource |
replaceDocument(Document document, RequestOptions options)
Replaces a document with the passed in document. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced document. In case of failure the Observable will error. |
Observable<Resource |
replaceDocument(String documentLink, Object document, RequestOptions options)
Replaces a document using a POJO object. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced document. In case of failure the Observable will error. |
Observable<Resource |
replaceOffer(Offer offer)
Replaces an offer. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced offer. In case of failure the Observable will error. |
Observable<Resource |
replacePermission(Permission permission, RequestOptions options)
Replaces a permission. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced permission. In case of failure the Observable will error. |
Observable<Resource |
replaceStoredProcedure(StoredProcedure storedProcedure, RequestOptions options)
Replaces a stored procedure. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced stored procedure. In case of failure the Observable will error. |
Observable<Resource |
replaceTrigger(Trigger trigger, RequestOptions options)
Replaces a trigger. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced trigger. In case of failure the Observable will error. |
Observable<Resource |
replaceUser(User user, RequestOptions options)
Replaces a user. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced user. In case of failure the Observable will error. |
Observable<Resource |
replaceUserDefinedFunction(UserDefinedFunction udf, RequestOptions options)
Replaces a user defined function. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced user defined function. In case of failure the Observable will error. |
Observable<Media |
updateMedia(String mediaLink, InputStream mediaStream, MediaOptions options)
Updates a media by the media link. |
Observable<Resource |
upsertAttachment(String documentLink, Attachment attachment, RequestOptions options)
Upserts an attachment. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted attachment. In case of failure the Observable will error. |
Observable<Resource |
upsertAttachment(String documentLink, InputStream mediaStream, MediaOptions options, RequestOptions requestOptions)
Upserts an attachment to the media stream After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted attachment. In case of failure the Observable will error. |
Observable<Resource |
upsertDocument(String collectionLink, Object document, RequestOptions options, boolean disableAutomaticIdGeneration)
Upserts a document. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted document. In case of failure the Observable will error. |
Observable<Resource |
upsertPermission(String userLink, Permission permission, RequestOptions options)
Upserts a permission. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted permission. In case of failure the Observable will error. |
Observable<Resource |
upsertStoredProcedure(String collectionLink, StoredProcedure storedProcedure, RequestOptions options)
Upserts a stored procedure. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted stored procedure. In case of failure the Observable will error. |
Observable<Resource |
upsertTrigger(String collectionLink, Trigger trigger, RequestOptions options)
Upserts a trigger. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted trigger. In case of failure the Observable will error. |
Observable<Resource |
upsertUser(String databaseLink, User user, RequestOptions options)
Upserts a user. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted user. In case of failure the Observable will error. |
Observable<Resource |
upsertUserDefinedFunction(String collectionLink, UserDefinedFunction udf, RequestOptions options)
Upserts a user defined function. After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted user defined function. In case of failure the Observable will error. |
Method Details
close
public void close()
Close this AsyncDocumentClient instance and cleans up the resources.
createAttachment
public Observable<>
Creates an attachment.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created attachment. In case of failure the Observable will error.
Parameters:
Returns:
createAttachment
public Observable<>
Creates an attachment.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created attachment. In case of failure the Observable will error.
Parameters:
Returns:
createCollection
public Observable<>
Creates a document collection.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created collection. In case of failure the Observable will error.
Parameters:
Returns:
createDatabase
public Observable<>
Creates a database.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created database. In case of failure the Observable will error.
Parameters:
Returns:
createDocument
public Observable<>
Creates a document.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created document. In case of failure the Observable will error.
Parameters:
Returns:
createPermission
public Observable<>
Creates a permission.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created permission. In case of failure the Observable will error.
Parameters:
Returns:
createStoredProcedure
public Observable<>
Creates a stored procedure.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created stored procedure. In case of failure the Observable will error.
Parameters:
Returns:
createTrigger
public Observable<>
Creates a trigger.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created trigger. In case of failure the Observable will error.
Parameters:
Returns:
createUser
public Observable<>
Creates a user.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created user. In case of failure the Observable will error.
Parameters:
Returns:
createUserDefinedFunction
public Observable<>
Creates a user defined function.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the created user defined function. In case of failure the Observable will error.
Parameters:
Returns:
deleteAttachment
public Observable<>
Deletes an attachment.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted attachment. In case of failure the Observable will error.
Parameters:
Returns:
deleteCollection
public Observable<>
Deletes a document collection by the collection link.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted database. In case of failure the Observable will error.
Parameters:
Returns:
deleteConflict
public Observable<>
Deletes a conflict.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted conflict. In case of failure the Observable will error.
Parameters:
Returns:
deleteDatabase
public Observable<>
Deletes a database.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the deleted database. In case of failure the Observable will error.
Parameters:
Returns:
deleteDocument
public Observable<>
Deletes a document by the document link.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted document. In case of failure the Observable will error.
Parameters:
Returns:
deletePermission
public Observable<>
Deletes a permission.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted permission. In case of failure the Observable will error.
Parameters:
Returns:
deleteStoredProcedure
public Observable<>
Deletes a stored procedure by the stored procedure link.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted stored procedure. In case of failure the Observable will error.
Parameters:
Returns:
deleteTrigger
public Observable<>
Deletes a trigger.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted trigger. In case of failure the Observable will error.
Parameters:
Returns:
deleteUser
public Observable<>
Deletes a user.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted user. In case of failure the Observable will error.
Parameters:
Returns:
deleteUserDefinedFunction
public Observable<>
Deletes a user defined function.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the deleted user defined function. In case of failure the Observable will error.
Parameters:
Returns:
executeStoredProcedure
public Observable
Executes a stored procedure by the stored procedure link.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the stored procedure response. In case of failure the Observable will error.
Parameters:
Returns:
executeStoredProcedure
public Observable
Executes a stored procedure by the stored procedure link.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the stored procedure response. In case of failure the Observable will error.
Parameters:
Returns:
getConnectionPolicy
public ConnectionPolicy getConnectionPolicy()
Gets the connection policy
Returns:
getDatabaseAccount
public Observable
Gets database account information.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the database account. In case of failure the Observable will error.
Returns:
getReadEndpoint
public URI getReadEndpoint()
Gets the current read endpoint chosen based on availability and preference.
Returns:
getServiceEndpoint
public URI getServiceEndpoint()
Gets the default service endpoint as passed in by the user during construction.
Returns:
getWriteEndpoint
public URI getWriteEndpoint()
Gets the current write endpoint chosen based on availability and preference.
Returns:
monitor
public static void monitor(MeterRegistry registry)
Adds a meter registry for reporting Direct TCP metrics
Parameters:
queryAttachments
public Observable<>
Query for attachments.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained attachments. In case of failure the Observable will error.
Parameters:
Returns:
queryAttachments
public Observable<>
Query for attachments.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained attachments. In case of failure the Observable will error.
Parameters:
Returns:
queryCollections
public Observable<>
Query for document collections in a database.
After subscription the operation will be performed. The Observable will contain one or several feed response of the obtained collections. In case of failure the Observable will error.
Parameters:
Returns:
queryCollections
public Observable<>
Query for document collections in a database.
After subscription the operation will be performed. The Observable will contain one or several feed response of the obtained collections. In case of failure the Observable will error.
Parameters:
Returns:
queryConflicts
public Observable<>
Query for conflicts.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained conflicts. In case of failure the Observable will error.
Parameters:
Returns:
queryConflicts
public Observable<>
Query for conflicts.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained conflicts. In case of failure the Observable will error.
Parameters:
Returns:
queryDatabases
public Observable<>
Query for databases.
After subscription the operation will be performed. The Observable will contain one or several feed response of the obtained databases. In case of failure the Observable will error.
Parameters:
Returns:
queryDatabases
public Observable<>
Query for databases.
After subscription the operation will be performed. The Observable will contain one or several feed response of the read databases. In case of failure the Observable will error.
Parameters:
Returns:
queryDocumentChangeFeed
public Observable<>
Query for documents change feed in a document collection. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained documents. In case of failure the Observable will error.
Parameters:
Returns:
queryDocuments
public Observable<>
Query for documents in a document collection.
After subscription the operation will be performed. The Observable will contain one or several feed response of the obtained documents. In case of failure the Observable will error.
Parameters:
Returns:
queryDocuments
public Observable<>
Query for documents in a document collection.
After subscription the operation will be performed. The Observable will contain one or several feed response of the obtained documents. In case of failure the Observable will error.
Parameters:
Returns:
queryOffers
public Observable<>
Query for offers in a database.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of obtained obtained offers. In case of failure the Observable will error.
Parameters:
Returns:
queryOffers
public Observable<>
Query for offers in a database.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of obtained obtained offers. In case of failure the Observable will error.
Parameters:
Returns:
queryPermissions
public Observable<>
Query for permissions.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained permissions. In case of failure the Observable will error.
Parameters:
Returns:
queryPermissions
public Observable<>
Query for permissions.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained permissions. In case of failure the Observable will error.
Parameters:
Returns:
queryStoredProcedures
public Observable<>
Query for stored procedures in a document collection.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained stored procedures. In case of failure the Observable will error.
Parameters:
Returns:
queryStoredProcedures
public Observable<>
Query for stored procedures in a document collection.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained stored procedures. In case of failure the Observable will error.
Parameters:
Returns:
queryTriggers
public Observable<>
Query for triggers.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained triggers. In case of failure the Observable will error.
Parameters:
Returns:
queryTriggers
public Observable<>
Query for triggers.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained triggers. In case of failure the Observable will error.
Parameters:
Returns:
queryUserDefinedFunctions
public Observable<>
Query for user defined functions.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained user defined functions. In case of failure the Observable will error.
Parameters:
Returns:
queryUserDefinedFunctions
public Observable<>
Query for user defined functions.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained user defined functions. In case of failure the Observable will error.
Parameters:
Returns:
queryUsers
public Observable<>
Query for users.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained users. In case of failure the Observable will error.
Parameters:
Returns:
queryUsers
public Observable<>
Query for users.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained users. In case of failure the Observable will error.
Parameters:
Returns:
readAttachment
public Observable<>
Reads an attachment.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read attachment. In case of failure the Observable will error.
Parameters:
Returns:
readAttachments
public Observable<>
Reads all attachments in a document.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read attachments. In case of failure the Observable will error.
Parameters:
Returns:
readCollection
public Observable<>
Reads a document collection by the collection link.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read collection. In case of failure the Observable will error.
Parameters:
Returns:
readCollections
public Observable<>
Reads all document collections in a database.
After subscription the operation will be performed. The Observable will contain one or several feed response of the read collections. In case of failure the Observable will error.
Parameters:
Returns:
readConflict
public Observable<>
Reads a conflict.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read conflict. In case of failure the Observable will error.
Parameters:
Returns:
readConflicts
public Observable<>
Reads all conflicts in a document collection.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read conflicts. In case of failure the Observable will error.
Parameters:
Returns:
readDatabase
public Observable<>
Reads a database.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read database. In case of failure the Observable will error.
Parameters:
Returns:
readDatabases
public Observable<>
Reads all databases.
After subscription the operation will be performed. The Observable will contain one or several feed response of the read databases. In case of failure the Observable will error.
Parameters:
Returns:
readDocument
public Observable<>
Reads a document by the document link.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read document. In case of failure the Observable will error.
Parameters:
Returns:
readDocuments
public Observable<>
Reads all documents in a document collection.
After subscription the operation will be performed. The Observable will contain one or several feed response of the read documents. In case of failure the Observable will error.
Parameters:
Returns:
readMedia
public Observable
Reads a media by the media link.
Parameters:
Returns:
readOffer
public Observable<>
Reads an offer.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read offer. In case of failure the Observable will error.
Parameters:
Returns:
readOffers
public Observable<>
Reads offers.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read offers. In case of failure the Observable will error.
Parameters:
Returns:
readPartitionKeyRanges
public Observable<>
Reads all partition key ranges in a document collection. After subscription the operation will be performed. The Observable will contain one or several feed response pages of the obtained partition key ranges. In case of failure the Observable will error.
Parameters:
Returns:
readPermission
public Observable<>
Reads a permission.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read permission. In case of failure the Observable will error.
Parameters:
Returns:
readPermissions
public Observable<>
Reads all permissions.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read permissions. In case of failure the Observable will error.
Parameters:
Returns:
readStoredProcedure
public Observable<>
Read a stored procedure by the stored procedure link.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read stored procedure. In case of failure the Observable will error.
Parameters:
Returns:
readStoredProcedures
public Observable<>
Reads all stored procedures in a document collection link.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read stored procedures. In case of failure the Observable will error.
Parameters:
Returns:
readTrigger
public Observable<>
Reads a trigger by the trigger link.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the read trigger. In case of failure the Observable will error.
Parameters:
Returns:
readTriggers
public Observable<>
Reads all triggers in a document collection.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read triggers. In case of failure the Observable will error.
Parameters:
Returns:
readUser
public Observable<>
Reads a user.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the read user. In case of failure the Observable will error.
Parameters:
Returns:
readUserDefinedFunction
public Observable<>
Read a user defined function.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response for the read user defined function. In case of failure the Observable will error.
Parameters:
Returns:
readUserDefinedFunctions
public Observable<>
Reads all user defined functions in a document collection.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read user defined functions. In case of failure the Observable will error.
Parameters:
Returns:
readUsers
public Observable<>
Reads all users in a database.
After subscription the operation will be performed. The Observable will contain one or several feed response pages of the read users. In case of failure the Observable will error.
Parameters:
Returns:
replaceAttachment
public Observable<>
Replaces an attachment.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced attachment. In case of failure the Observable will error.
Parameters:
Returns:
replaceCollection
public Observable<>
Replaces a document collection.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced document collection. In case of failure the Observable will error.
Parameters:
Returns:
replaceDocument
public Observable<>
Replaces a document with the passed in document.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced document. In case of failure the Observable will error.
Parameters:
Returns:
replaceDocument
public Observable<>
Replaces a document using a POJO object.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced document. In case of failure the Observable will error.
Parameters:
Returns:
replaceOffer
public Observable<>
Replaces an offer.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced offer. In case of failure the Observable will error.
Parameters:
Returns:
replacePermission
public Observable<>
Replaces a permission.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced permission. In case of failure the Observable will error.
Parameters:
Returns:
replaceStoredProcedure
public Observable<>
Replaces a stored procedure.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced stored procedure. In case of failure the Observable will error.
Parameters:
Returns:
replaceTrigger
public Observable<>
Replaces a trigger.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced trigger. In case of failure the Observable will error.
Parameters:
Returns:
replaceUser
public Observable<>
Replaces a user.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced user. In case of failure the Observable will error.
Parameters:
Returns:
replaceUserDefinedFunction
public Observable<>
Replaces a user defined function.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the replaced user defined function. In case of failure the Observable will error.
Parameters:
Returns:
updateMedia
public Observable
Updates a media by the media link.
Parameters:
Returns:
upsertAttachment
public Observable<>
Upserts an attachment.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted attachment. In case of failure the Observable will error.
Parameters:
Returns:
upsertAttachment
public Observable<>
Upserts an attachment to the media stream
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted attachment. In case of failure the Observable will error.
Parameters:
Returns:
upsertDocument
public Observable<>
Upserts a document.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted document. In case of failure the Observable will error.
Parameters:
Returns:
upsertPermission
public Observable<>
Upserts a permission.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted permission. In case of failure the Observable will error.
Parameters:
Returns:
upsertStoredProcedure
public Observable<>
Upserts a stored procedure.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted stored procedure. In case of failure the Observable will error.
Parameters:
Returns:
upsertTrigger
public Observable<>
Upserts a trigger.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted trigger. In case of failure the Observable will error.
Parameters:
Returns:
upsertUser
public Observable<>
Upserts a user.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted user. In case of failure the Observable will error.
Parameters:
Returns:
upsertUserDefinedFunction
public Observable<>
Upserts a user defined function.
After subscription the operation will be performed. The Observable upon successful completion will contain a single resource response with the upserted user defined function. In case of failure the Observable will error.
Parameters:
Returns:
Applies to
Azure SDK for Java
Visszajelzés
https://aka.ms/ContentUserFeedback.
Hamarosan elérhető: 2024-ben fokozatosan kivezetjük a GitHub-problémákat a tartalom visszajelzési mechanizmusaként, és lecseréljük egy új visszajelzési rendszerre. További információ:Visszajelzés küldése és megtekintése a következőhöz: