public final class BridgeInternal extends Object
Constructor and Description |
---|
BridgeInternal() |
Modifier and Type | Method and Description |
---|---|
static CosmosAsyncConflict |
createCosmosAsyncConflict(String id,
CosmosAsyncContainer container) |
static CosmosAsyncContainer |
createCosmosAsyncContainer(String id,
CosmosAsyncDatabase database) |
static CosmosAsyncDatabase |
createCosmosAsyncDatabase(String id,
CosmosAsyncClient client) |
static CosmosAsyncPermission |
createCosmosAsyncPermission(String id,
CosmosAsyncUser user) |
static CosmosAsyncStoredProcedure |
createCosmosAsyncStoredProcedure(String id,
CosmosAsyncContainer cosmosContainer) |
static CosmosAsyncTrigger |
createCosmosAsyncTrigger(String id,
CosmosAsyncContainer container) |
static CosmosAsyncUser |
createCosmosAsyncUser(String id,
CosmosAsyncDatabase database) |
static CosmosAsyncUserDefinedFunction |
createCosmosAsyncUserDefinedFunction(String id,
CosmosAsyncContainer container) |
static CosmosClientException |
createCosmosClientException(int statusCode) |
static CosmosClientException |
createCosmosClientException(int statusCode,
CosmosError cosmosErrorResource,
Map<String,String> responseHeaders) |
static CosmosClientException |
createCosmosClientException(int statusCode,
Exception innerException) |
static CosmosClientException |
createCosmosClientException(int statusCode,
String errorMessage) |
static CosmosClientException |
createCosmosClientException(String message,
Exception exception,
Map<String,String> responseHeaders,
int statusCode,
String resourceAddress) |
static CosmosClientException |
createCosmosClientException(String resourceAddress,
int statusCode,
CosmosError cosmosErrorResource,
Map<String,String> responseHeaders) |
static CosmosContainer |
createCosmosContainer(String id,
CosmosDatabase database,
CosmosAsyncContainer container) |
static CosmosDatabase |
createCosmosDatabase(String id,
CosmosClient client,
CosmosAsyncDatabase database) |
static CosmosResponseDiagnostics |
createCosmosResponseDiagnostics() |
static CosmosStoredProcedureProperties |
createCosmosStoredProcedureProperties(String jsonString) |
static CosmosUser |
createCosmosUser(CosmosAsyncUser asyncUser,
CosmosDatabase database,
String id) |
static <T> FeedResponse<T> |
createFeedResponse(List<T> results,
Map<String,String> headers) |
static FeedResponseDiagnostics |
createFeedResponseDiagnostics(Map<String,com.azure.cosmos.implementation.QueryMetrics> queryMetricsMap) |
static <T> FeedResponse<T> |
createFeedResponseWithQueryMetrics(List<T> results,
Map<String,String> headers,
ConcurrentMap<String,com.azure.cosmos.implementation.QueryMetrics> queryMetricsMap) |
static com.azure.cosmos.implementation.QueryMetrics |
createQueryMetricsFromCollection(Collection<com.azure.cosmos.implementation.QueryMetrics> queryMetricsCollection) |
static com.azure.cosmos.implementation.QueryMetrics |
createQueryMetricsFromDelimitedStringAndClientSideMetrics(String queryMetricsDelimitedString,
com.azure.cosmos.implementation.query.metrics.ClientSideMetrics clientSideMetrics,
String activityId) |
static com.azure.cosmos.implementation.Document |
documentFromObject(Object document,
com.fasterxml.jackson.databind.ObjectMapper mapper) |
static com.azure.cosmos.implementation.Configs |
extractConfigs(CosmosClientBuilder cosmosClientBuilder) |
static String |
extractContainerSelfLink(CosmosAsyncContainer container) |
static String |
extractResourceSelfLink(Resource resource) |
static ConsistencyLevel |
fromServiceSerializedFormat(String consistencyLevel) |
static String |
getAltLink(Resource resource) |
static com.azure.cosmos.implementation.query.metrics.ClientSideMetrics |
getClientSideMetrics(com.azure.cosmos.implementation.QueryMetrics queryMetrics) |
static List<URI> |
getContactedReplicas(CosmosResponseDiagnostics cosmosResponseDiagnostics) |
static Set<URI> |
getFailedReplicas(CosmosResponseDiagnostics cosmosResponseDiagnostics) |
static Map<String,String> |
getFeedHeaders(com.azure.cosmos.implementation.ChangeFeedOptions options) |
static Map<String,String> |
getFeedHeaders(FeedOptions options) |
static int |
getHashCode(CosmosKeyCredential keyCredential) |
static String |
getInnerErrorMessage(CosmosClientException cosmosClientException) |
static String |
getLink(CosmosAsyncContainer cosmosAsyncContainer) |
static <E extends CosmosClientException> |
getLSN(E e) |
static com.fasterxml.jackson.databind.node.ObjectNode |
getObject(JsonSerializable jsonSerializable,
String propertyName) |
static PartitionKey |
getPartitionKey(com.azure.cosmos.implementation.routing.PartitionKeyInternal partitionKeyInternal) |
static com.azure.cosmos.implementation.routing.PartitionKeyInternal |
getPartitionKeyInternal(PartitionKey partitionKey) |
static <E extends CosmosClientException> |
getPartitionKeyRangeId(E e) |
static <T> com.azure.cosmos.implementation.CosmosItemProperties |
getProperties(CosmosAsyncItemResponse<T> cosmosItemResponse) |
static <T> com.azure.cosmos.implementation.CosmosItemProperties |
getProperties(CosmosItemResponse<T> cosmosItemResponse) |
static <E extends CosmosClientException> |
getRequestHeaders(CosmosClientException cosmosClientException) |
static <E extends CosmosClientException> |
getRequestUri(CosmosClientException cosmosClientException) |
static <E extends CosmosClientException> |
getResourceAddress(E e) |
static boolean |
getUseMultipleWriteLocations(ConnectionPolicy policy) |
static Object |
getValue(com.fasterxml.jackson.databind.JsonNode value) |
static CosmosClientBuilder |
injectConfigs(CosmosClientBuilder cosmosClientBuilder,
com.azure.cosmos.implementation.Configs configs) |
static boolean |
isEnableMultipleWriteLocations(com.azure.cosmos.implementation.DatabaseAccount account) |
static void |
monitorTelemetry(io.micrometer.core.instrument.MeterRegistry registry) |
static <T extends Resource> |
noChanges(FeedResponse<T> page) |
static <T extends Resource> |
noChanges(com.azure.cosmos.implementation.RxDocumentServiceResponse rsp) |
static <T extends Resource> |
putQueryMetricsIntoMap(FeedResponse<T> response,
String partitionKeyRangeId,
com.azure.cosmos.implementation.QueryMetrics queryMetrics) |
static <T> ConcurrentMap<String,com.azure.cosmos.implementation.QueryMetrics> |
queryMetricsFromFeedResponse(FeedResponse<T> feedResponse) |
static void |
recordAddressResolutionEnd(CosmosResponseDiagnostics cosmosResponseDiagnostics,
String identifier) |
static String |
recordAddressResolutionStart(CosmosResponseDiagnostics cosmosResponseDiagnostics,
URI targetEndpoint) |
static void |
recordGatewayResponse(CosmosResponseDiagnostics cosmosResponseDiagnostics,
com.azure.cosmos.implementation.RxDocumentServiceRequest rxDocumentServiceRequest,
com.azure.cosmos.implementation.directconnectivity.StoreResponse storeResponse,
CosmosClientException exception) |
static void |
recordResponse(CosmosResponseDiagnostics cosmosResponseDiagnostics,
com.azure.cosmos.implementation.RxDocumentServiceRequest request,
com.azure.cosmos.implementation.directconnectivity.StoreResult storeResult) |
static void |
recordRetryContext(CosmosResponseDiagnostics cosmosResponseDiagnostics,
com.azure.cosmos.implementation.RxDocumentServiceRequest request) |
static void |
remove(JsonSerializable jsonSerializable,
String propertyName) |
static ByteBuffer |
serializeJsonToByteBuffer(Object document,
com.fasterxml.jackson.databind.ObjectMapper mapper) |
static void |
setAltLink(Resource resource,
String altLink) |
static void |
setContactedReplicas(CosmosResponseDiagnostics cosmosResponseDiagnostics,
List<URI> contactedReplicas) |
static CosmosClientException |
setCosmosResponseDiagnostics(CosmosClientException cosmosClientException,
CosmosResponseDiagnostics cosmosResponseDiagnostics) |
static void |
setFeedOptionsContinuationToken(FeedOptions feedOptions,
String continuationToken) |
static void |
setFeedOptionsContinuationTokenAndMaxItemCount(FeedOptions feedOptions,
String continuationToken,
Integer maxItemCount) |
static void |
setFeedOptionsMaxItemCount(FeedOptions feedOptions,
Integer maxItemCount) |
static <E extends CosmosClientException> |
setLSN(E e,
long lsn) |
static void |
setMaxReplicaSetSize(com.azure.cosmos.implementation.ReplicationPolicy replicationPolicy,
int value) |
static <E extends CosmosClientException> |
setPartitionKeyRangeId(E e,
String partitionKeyRangeId) |
static <T> void |
setProperty(JsonSerializable jsonSerializable,
String propertyName,
T value) |
static <E extends CosmosClientException> |
setRequestHeaders(CosmosClientException cosmosClientException,
Map<String,String> requestHeaders) |
static <E extends CosmosClientException> |
setResourceAddress(E e,
String resourceAddress) |
static void |
setResourceSelfLink(Resource resource,
String selfLink) |
static void |
setTimestamp(Resource resource,
OffsetDateTime date) |
static void |
setTransportClientRequestTimelineOnDiagnostics(CosmosResponseDiagnostics cosmosResponseDiagnostics,
com.azure.cosmos.implementation.RequestTimeline requestTimeline) |
static void |
setUseMultipleWriteLocations(ConnectionPolicy policy,
boolean value) |
static <T extends Resource> |
toChaneFeedResponsePage(com.azure.cosmos.implementation.RxDocumentServiceResponse response,
Class<T> cls) |
static <T> FeedResponse<T> |
toFeedResponsePage(List<T> results,
Map<String,String> headers,
boolean noChanges) |
static <T extends Resource> |
toFeedResponsePage(com.azure.cosmos.implementation.RxDocumentServiceResponse response,
Class<T> cls) |
static <T extends Resource> |
toResourceResponse(com.azure.cosmos.implementation.RxDocumentServiceResponse response,
Class<T> cls) |
static com.azure.cosmos.implementation.StoredProcedureResponse |
toStoredProcedureResponse(com.azure.cosmos.implementation.RxDocumentServiceResponse response) |
public static com.azure.cosmos.implementation.Document documentFromObject(Object document, com.fasterxml.jackson.databind.ObjectMapper mapper)
public static ByteBuffer serializeJsonToByteBuffer(Object document, com.fasterxml.jackson.databind.ObjectMapper mapper)
public static void monitorTelemetry(io.micrometer.core.instrument.MeterRegistry registry)
public static <T extends Resource> com.azure.cosmos.implementation.ResourceResponse<T> toResourceResponse(com.azure.cosmos.implementation.RxDocumentServiceResponse response, Class<T> cls)
public static <T extends Resource> FeedResponse<T> toFeedResponsePage(com.azure.cosmos.implementation.RxDocumentServiceResponse response, Class<T> cls)
public static <T> FeedResponse<T> toFeedResponsePage(List<T> results, Map<String,String> headers, boolean noChanges)
public static <T extends Resource> FeedResponse<T> toChaneFeedResponsePage(com.azure.cosmos.implementation.RxDocumentServiceResponse response, Class<T> cls)
public static com.azure.cosmos.implementation.StoredProcedureResponse toStoredProcedureResponse(com.azure.cosmos.implementation.RxDocumentServiceResponse response)
public static Map<String,String> getFeedHeaders(com.azure.cosmos.implementation.ChangeFeedOptions options)
public static Map<String,String> getFeedHeaders(FeedOptions options)
public static <T extends Resource> boolean noChanges(FeedResponse<T> page)
public static <T extends Resource> boolean noChanges(com.azure.cosmos.implementation.RxDocumentServiceResponse rsp)
public static <T> FeedResponse<T> createFeedResponse(List<T> results, Map<String,String> headers)
public static <T> FeedResponse<T> createFeedResponseWithQueryMetrics(List<T> results, Map<String,String> headers, ConcurrentMap<String,com.azure.cosmos.implementation.QueryMetrics> queryMetricsMap)
public static FeedResponseDiagnostics createFeedResponseDiagnostics(Map<String,com.azure.cosmos.implementation.QueryMetrics> queryMetricsMap)
public static <E extends CosmosClientException> E setResourceAddress(E e, String resourceAddress)
public static <E extends CosmosClientException> long getLSN(E e)
public static <E extends CosmosClientException> String getPartitionKeyRangeId(E e)
public static <E extends CosmosClientException> String getResourceAddress(E e)
public static <E extends CosmosClientException> E setLSN(E e, long lsn)
public static <E extends CosmosClientException> E setPartitionKeyRangeId(E e, String partitionKeyRangeId)
public static boolean isEnableMultipleWriteLocations(com.azure.cosmos.implementation.DatabaseAccount account)
public static boolean getUseMultipleWriteLocations(ConnectionPolicy policy)
public static void setUseMultipleWriteLocations(ConnectionPolicy policy, boolean value)
public static <E extends CosmosClientException> com.azure.cosmos.implementation.directconnectivity.Uri getRequestUri(CosmosClientException cosmosClientException)
public static <E extends CosmosClientException> void setRequestHeaders(CosmosClientException cosmosClientException, Map<String,String> requestHeaders)
public static <E extends CosmosClientException> Map<String,String> getRequestHeaders(CosmosClientException cosmosClientException)
public static void setMaxReplicaSetSize(com.azure.cosmos.implementation.ReplicationPolicy replicationPolicy, int value)
public static <T extends Resource> void putQueryMetricsIntoMap(FeedResponse<T> response, String partitionKeyRangeId, com.azure.cosmos.implementation.QueryMetrics queryMetrics)
public static com.azure.cosmos.implementation.QueryMetrics createQueryMetricsFromDelimitedStringAndClientSideMetrics(String queryMetricsDelimitedString, com.azure.cosmos.implementation.query.metrics.ClientSideMetrics clientSideMetrics, String activityId)
public static com.azure.cosmos.implementation.QueryMetrics createQueryMetricsFromCollection(Collection<com.azure.cosmos.implementation.QueryMetrics> queryMetricsCollection)
public static com.azure.cosmos.implementation.query.metrics.ClientSideMetrics getClientSideMetrics(com.azure.cosmos.implementation.QueryMetrics queryMetrics)
public static String getInnerErrorMessage(CosmosClientException cosmosClientException)
public static PartitionKey getPartitionKey(com.azure.cosmos.implementation.routing.PartitionKeyInternal partitionKeyInternal)
public static <T> void setProperty(JsonSerializable jsonSerializable, String propertyName, T value)
public static com.fasterxml.jackson.databind.node.ObjectNode getObject(JsonSerializable jsonSerializable, String propertyName)
public static void remove(JsonSerializable jsonSerializable, String propertyName)
public static CosmosStoredProcedureProperties createCosmosStoredProcedureProperties(String jsonString)
public static Object getValue(com.fasterxml.jackson.databind.JsonNode value)
public static CosmosClientException setCosmosResponseDiagnostics(CosmosClientException cosmosClientException, CosmosResponseDiagnostics cosmosResponseDiagnostics)
public static CosmosClientException createCosmosClientException(int statusCode)
public static CosmosClientException createCosmosClientException(int statusCode, String errorMessage)
public static CosmosClientException createCosmosClientException(int statusCode, Exception innerException)
public static CosmosClientException createCosmosClientException(int statusCode, CosmosError cosmosErrorResource, Map<String,String> responseHeaders)
public static CosmosClientException createCosmosClientException(String resourceAddress, int statusCode, CosmosError cosmosErrorResource, Map<String,String> responseHeaders)
public static CosmosClientException createCosmosClientException(String message, Exception exception, Map<String,String> responseHeaders, int statusCode, String resourceAddress)
public static com.azure.cosmos.implementation.Configs extractConfigs(CosmosClientBuilder cosmosClientBuilder)
public static CosmosClientBuilder injectConfigs(CosmosClientBuilder cosmosClientBuilder, com.azure.cosmos.implementation.Configs configs)
public static String extractContainerSelfLink(CosmosAsyncContainer container)
public static void setTimestamp(Resource resource, OffsetDateTime date)
public static CosmosResponseDiagnostics createCosmosResponseDiagnostics()
public static void setTransportClientRequestTimelineOnDiagnostics(CosmosResponseDiagnostics cosmosResponseDiagnostics, com.azure.cosmos.implementation.RequestTimeline requestTimeline)
public static void recordResponse(CosmosResponseDiagnostics cosmosResponseDiagnostics, com.azure.cosmos.implementation.RxDocumentServiceRequest request, com.azure.cosmos.implementation.directconnectivity.StoreResult storeResult)
public static void recordRetryContext(CosmosResponseDiagnostics cosmosResponseDiagnostics, com.azure.cosmos.implementation.RxDocumentServiceRequest request)
public static void recordGatewayResponse(CosmosResponseDiagnostics cosmosResponseDiagnostics, com.azure.cosmos.implementation.RxDocumentServiceRequest rxDocumentServiceRequest, com.azure.cosmos.implementation.directconnectivity.StoreResponse storeResponse, CosmosClientException exception)
public static String recordAddressResolutionStart(CosmosResponseDiagnostics cosmosResponseDiagnostics, URI targetEndpoint)
public static void recordAddressResolutionEnd(CosmosResponseDiagnostics cosmosResponseDiagnostics, String identifier)
public static List<URI> getContactedReplicas(CosmosResponseDiagnostics cosmosResponseDiagnostics)
public static void setContactedReplicas(CosmosResponseDiagnostics cosmosResponseDiagnostics, List<URI> contactedReplicas)
public static Set<URI> getFailedReplicas(CosmosResponseDiagnostics cosmosResponseDiagnostics)
public static <T> ConcurrentMap<String,com.azure.cosmos.implementation.QueryMetrics> queryMetricsFromFeedResponse(FeedResponse<T> feedResponse)
public static com.azure.cosmos.implementation.routing.PartitionKeyInternal getPartitionKeyInternal(PartitionKey partitionKey)
public static void setFeedOptionsContinuationTokenAndMaxItemCount(FeedOptions feedOptions, String continuationToken, Integer maxItemCount)
public static void setFeedOptionsContinuationToken(FeedOptions feedOptions, String continuationToken)
public static void setFeedOptionsMaxItemCount(FeedOptions feedOptions, Integer maxItemCount)
public static <T> com.azure.cosmos.implementation.CosmosItemProperties getProperties(CosmosAsyncItemResponse<T> cosmosItemResponse)
public static <T> com.azure.cosmos.implementation.CosmosItemProperties getProperties(CosmosItemResponse<T> cosmosItemResponse)
public static int getHashCode(CosmosKeyCredential keyCredential)
public static String getLink(CosmosAsyncContainer cosmosAsyncContainer)
public static CosmosAsyncConflict createCosmosAsyncConflict(String id, CosmosAsyncContainer container)
public static CosmosAsyncContainer createCosmosAsyncContainer(String id, CosmosAsyncDatabase database)
public static CosmosAsyncDatabase createCosmosAsyncDatabase(String id, CosmosAsyncClient client)
public static CosmosAsyncPermission createCosmosAsyncPermission(String id, CosmosAsyncUser user)
public static CosmosAsyncStoredProcedure createCosmosAsyncStoredProcedure(String id, CosmosAsyncContainer cosmosContainer)
public static CosmosAsyncTrigger createCosmosAsyncTrigger(String id, CosmosAsyncContainer container)
public static CosmosAsyncUserDefinedFunction createCosmosAsyncUserDefinedFunction(String id, CosmosAsyncContainer container)
public static CosmosAsyncUser createCosmosAsyncUser(String id, CosmosAsyncDatabase database)
public static CosmosContainer createCosmosContainer(String id, CosmosDatabase database, CosmosAsyncContainer container)
public static CosmosDatabase createCosmosDatabase(String id, CosmosClient client, CosmosAsyncDatabase database)
public static CosmosUser createCosmosUser(CosmosAsyncUser asyncUser, CosmosDatabase database, String id)
public static ConsistencyLevel fromServiceSerializedFormat(String consistencyLevel)
Copyright © 2020 Microsoft Corporation. All rights reserved.