BridgeInternal Class

Package:
com.azure.cosmos
Maven Artifact:
com.azure:azure-cosmos:4.80.0
  • java.lang.Object
    • com.azure.cosmos.BridgeInternal

public final class BridgeInternal

DO NOT USE. This is meant to be used only internally as a bridge access to classes in com.azure.cosmos

Method Summary

Modifier and Type Method and Description
static CosmosDiagnostics cloneCosmosDiagnostics(CosmosDiagnostics toBeCloned)
static CosmosDiagnostics createCosmosDiagnostics(Map<String,QueryMetrics> queryMetricsMap)
static CosmosException createCosmosException(int statusCode)
static CosmosException createCosmosException(int statusCode, String errorMessage)
static CosmosException createCosmosException(String message, Exception exception, Map<String,String> responseHeaders, int statusCode, String resourceAddress)
static CosmosException createCosmosException(String resourceAddress, int statusCode, CosmosError cosmosErrorResource, Map<String,String> responseHeaders)
static CosmosException createCosmosException(String resourceAddress, int statusCode, Exception innerException)
static CosmosStoredProcedureProperties createCosmosStoredProcedureProperties(String jsonString)
static FeedResponse<T> createFeedResponseWithQueryMetrics(List<T> results, Map<String,String> headers, ConcurrentMap<String,QueryMetrics> queryMetricsMap, QueryInfo.QueryPlanDiagnosticsContext diagnosticsContext, boolean useEtagAsContinuation, boolean isNoChangesResponse, CosmosDiagnostics cosmosDiagnostics)
static com.azure.cosmos.implementation.QueryMetrics createQueryMetricsFromCollection(Collection<QueryMetrics> queryMetricsCollection)
static com.azure.cosmos.implementation.QueryMetrics createQueryMetricsFromDelimitedStringAndClientSideMetrics(String queryMetricsDelimitedString, ClientSideMetrics clientSideMetrics, String activityId, String indexUtilizationInfoJSONString)
static CosmosException createServiceUnavailableException(Exception innerException, int subStatusCode)
static com.azure.cosmos.implementation.Configs extractConfigs(CosmosClientBuilder cosmosClientBuilder)
static String extractContainerSelfLink(CosmosAsyncContainer container)
static ConsistencyLevel fromServiceSerializedFormat(String consistencyLevel)
static String getAltLink(Resource resource)
static com.azure.cosmos.implementation.directconnectivity.rntbd.RntbdChannelAcquisitionTimeline getChannelAcqusitionTimeline(E e)
static com.azure.cosmos.implementation.query.metrics.ClientSideMetrics getClientSideMetrics(QueryMetrics queryMetrics)
static com.azure.cosmos.implementation.ClientSideRequestStatistics getClientSideRequestStatics(CosmosDiagnostics cosmosDiagnostics)
static List<URI> getContactedReplicas(CosmosDiagnostics cosmosDiagnostics)
static com.azure.cosmos.implementation.AsyncDocumentClient getContextClient(CosmosAsyncClient cosmosAsyncClient)
static CosmosAsyncContainer getControlContainerFromThroughputGlobalControlConfig(GlobalThroughputControlConfig globalControlConfig)
static com.azure.cosmos.implementation.CosmosError getCosmosError(CosmosException cosmosException)
static Set<URI> getFailedReplicas(CosmosDiagnostics cosmosDiagnostics)
static String getInnerErrorMessage(CosmosException cosmosException)
static String getLink(CosmosAsyncContainer cosmosAsyncContainer)
static long getLSN(E e)
static com.azure.cosmos.implementation.MetadataDiagnosticsContext getMetaDataDiagnosticContext(CosmosDiagnostics cosmosDiagnostics)
static Duration getNetworkRequestTimeoutFromGatewayConnectionConfig(GatewayConnectionConfig gatewayConnectionConfig)
static SqlQuerySpec getOfferQuerySpecFromResourceId(CosmosAsyncContainer container, String resourceId)
static PartitionKey getPartitionKey(PartitionKeyInternal partitionKeyInternal)
static com.azure.cosmos.implementation.routing.PartitionKeyInternal getPartitionKeyInternal(PartitionKey partitionKey)
static String getPartitionKeyRangeId(E e)
static com.azure.cosmos.implementation.InternalObjectNode getProperties(CosmosItemResponse<T> cosmosItemResponse)
static Set<String> getRegionsContacted(CosmosDiagnostics cosmosDiagnostics)
static int getRequestBodyLength(E e)
static Map<String,String> getRequestHeaders(CosmosException cosmosException)
static com.azure.cosmos.implementation.RequestTimeline getRequestTimeline(E e)
static String getResourceAddress(E e)
static com.azure.cosmos.implementation.RetryContext getRetryContext(CosmosDiagnostics cosmosDiagnostics)
static int getRntbdRequestLength(E e)
static int getRntbdResponseLength(E e)
static com.azure.cosmos.implementation.SerializationDiagnosticsContext getSerializationDiagnosticsContext(CosmosDiagnostics cosmosDiagnostics)
static String getServiceEndpoint(CosmosAsyncClient cosmosAsyncClient)
static com.azure.cosmos.implementation.directconnectivity.rntbd.RntbdEndpointStatistics getServiceEndpointStatistics(E e)
static boolean hasSendingRequestStarted(E e)
static void initializeAllAccessors()
static CosmosClientBuilder injectConfigs(CosmosClientBuilder cosmosClientBuilder, Configs configs)
static boolean isEnableMultipleWriteLocations(DatabaseAccount account)
static void monitorTelemetry(MeterRegistry registry)
static boolean noChanges(FeedResponse<T> page)
static void putQueryMetricsIntoMap(FeedResponse<T> response, String partitionKeyRangeId, QueryMetrics queryMetrics)
static ConcurrentMap<String,com.azure.cosmos.implementation.QueryMetrics> queryMetricsFromFeedResponse(FeedResponse<T> feedResponse)
static String recordAddressResolutionStart(CosmosDiagnostics cosmosDiagnostics, URI targetEndpoint, boolean forceRefresh, boolean forceCollectionRoutingMapRefresh)
static void recordGatewayResponse(CosmosDiagnostics cosmosDiagnostics, RxDocumentServiceRequest rxDocumentServiceRequest, CosmosException cosmosException, GlobalEndpointManager globalEndpointManager)
static void recordGatewayResponse(CosmosDiagnostics cosmosDiagnostics, RxDocumentServiceRequest rxDocumentServiceRequest, StoreResponse storeResponse, GlobalEndpointManager globalEndpointManager)
static void recordResponse(CosmosDiagnostics cosmosDiagnostics, RxDocumentServiceRequest request, StoreResult storeResult, GlobalEndpointManager globalEndpointManager)
static void recordRetryContextEndTime(CosmosDiagnostics cosmosDiagnostics)
static void setAltLink(Resource resource, String altLink)
static E setChannelAcquisitionTimeline(E e, RntbdChannelAcquisitionTimeline channelAcquisitionTimeline)
static void setContactedReplicas(CosmosDiagnostics cosmosDiagnostics, List<URI> contactedReplicas)
static CosmosException setCosmosDiagnostics(CosmosException cosmosException, CosmosDiagnostics cosmosDiagnostics)
static void setFeedResponseDiagnostics(CosmosDiagnostics cosmosDiagnostics, ConcurrentMap<String,QueryMetrics> queryMetricsMap)
static E setLSN(E e, long lsn)
static void setMaxReplicaSetSize(ReplicationPolicy replicationPolicy, int value)
static E setPartitionKeyRangeId(E e, String partitionKeyRangeId)
static void setQueryPlanDiagnosticsContext(CosmosDiagnostics cosmosDiagnostics, QueryInfo.QueryPlanDiagnosticsContext diagnosticsContext)
static E setRequestBodyLength(E e, int requestLen)
static void setRequestHeaders(CosmosException cosmosException, Map<String,String> requestHeaders)
static E setRequestTimeline(E e, RequestTimeline requestTimeline)
static E setResourceAddress(E e, String resourceAddress)
static E setRntbdRequestLength(E e, int requestLen)
static E setRntbdResponseLength(E e, int requestLen)
static void setSendingRequestStarted(E e, boolean hasSendingRequestStarted)
static E setServiceEndpointStatistics(E e, RntbdEndpointStatistics rntbdEndpointStatistics)
static void setSubStatusCode(CosmosException documentClientException, int subStatusCode)
static FeedResponse<T> toFeedResponsePage(List<T> results, Map<String,String> headers, boolean noChanges, CosmosDiagnostics diagnostics)
static com.azure.cosmos.implementation.ResourceResponse<T> toResourceResponse(RxDocumentServiceResponse response, Class<T> cls)
static com.azure.cosmos.implementation.StoredProcedureResponse toStoredProcedureResponse(RxDocumentServiceResponse response)

Methods inherited from java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Method Details

cloneCosmosDiagnostics

public static CosmosDiagnostics cloneCosmosDiagnostics(CosmosDiagnostics toBeCloned)

Parameters:

toBeCloned

createCosmosDiagnostics

public static CosmosDiagnostics createCosmosDiagnostics(Map<String,QueryMetrics> queryMetricsMap)

Parameters:

queryMetricsMap

createCosmosException

public static CosmosException createCosmosException(int statusCode)

Parameters:

statusCode

createCosmosException

public static CosmosException createCosmosException(int statusCode, String errorMessage)

Parameters:

statusCode
errorMessage

createCosmosException

public static CosmosException createCosmosException(String message, Exception exception, Map<String,String> responseHeaders, int statusCode, String resourceAddress)

Parameters:

message
exception
responseHeaders
statusCode
resourceAddress

createCosmosException

public static CosmosException createCosmosException(String resourceAddress, int statusCode, CosmosError cosmosErrorResource, Map<String,String> responseHeaders)

Parameters:

resourceAddress
statusCode
cosmosErrorResource
responseHeaders

createCosmosException

public static CosmosException createCosmosException(String resourceAddress, int statusCode, Exception innerException)

Parameters:

resourceAddress
statusCode
innerException

createCosmosStoredProcedureProperties

public static CosmosStoredProcedureProperties createCosmosStoredProcedureProperties(String jsonString)

Parameters:

jsonString

createFeedResponseWithQueryMetrics

public static FeedResponse<T> <T>createFeedResponseWithQueryMetrics(List<T> results, Map<String,String> headers, ConcurrentMap<String,QueryMetrics> queryMetricsMap, QueryInfo.QueryPlanDiagnosticsContext diagnosticsContext, boolean useEtagAsContinuation, boolean isNoChangesResponse, CosmosDiagnostics cosmosDiagnostics)

Parameters:

results
headers
queryMetricsMap
diagnosticsContext
useEtagAsContinuation
isNoChangesResponse
cosmosDiagnostics

createQueryMetricsFromCollection

public static QueryMetrics createQueryMetricsFromCollection(Collection<QueryMetrics> queryMetricsCollection)

Parameters:

queryMetricsCollection

createQueryMetricsFromDelimitedStringAndClientSideMetrics

public static QueryMetrics createQueryMetricsFromDelimitedStringAndClientSideMetrics(String queryMetricsDelimitedString, ClientSideMetrics clientSideMetrics, String activityId, String indexUtilizationInfoJSONString)

Parameters:

queryMetricsDelimitedString
clientSideMetrics
activityId
indexUtilizationInfoJSONString

createServiceUnavailableException

public static CosmosException createServiceUnavailableException(Exception innerException, int subStatusCode)

Parameters:

innerException
subStatusCode

extractConfigs

public static Configs extractConfigs(CosmosClientBuilder cosmosClientBuilder)

Parameters:

cosmosClientBuilder

extractContainerSelfLink

public static String extractContainerSelfLink(CosmosAsyncContainer container)

Parameters:

container

fromServiceSerializedFormat

public static ConsistencyLevel fromServiceSerializedFormat(String consistencyLevel)

Parameters:

consistencyLevel

getAltLink

public static String getAltLink(Resource resource)

Parameters:

resource

getChannelAcqusitionTimeline

public static RntbdChannelAcquisitionTimeline <E>getChannelAcqusitionTimeline(E e)

Parameters:

e

getClientSideMetrics

public static ClientSideMetrics getClientSideMetrics(QueryMetrics queryMetrics)

Parameters:

queryMetrics

getClientSideRequestStatics

public static ClientSideRequestStatistics getClientSideRequestStatics(CosmosDiagnostics cosmosDiagnostics)

Parameters:

cosmosDiagnostics

getContactedReplicas

public static List<URI> getContactedReplicas(CosmosDiagnostics cosmosDiagnostics)

Parameters:

cosmosDiagnostics

getContextClient

public static AsyncDocumentClient getContextClient(CosmosAsyncClient cosmosAsyncClient)

Parameters:

cosmosAsyncClient

getControlContainerFromThroughputGlobalControlConfig

public static CosmosAsyncContainer getControlContainerFromThroughputGlobalControlConfig(GlobalThroughputControlConfig globalControlConfig)

Parameters:

globalControlConfig

getCosmosError

public static CosmosError getCosmosError(CosmosException cosmosException)

Parameters:

cosmosException

getFailedReplicas

public static Set<URI> getFailedReplicas(CosmosDiagnostics cosmosDiagnostics)

Parameters:

cosmosDiagnostics

getInnerErrorMessage

public static String getInnerErrorMessage(CosmosException cosmosException)

Parameters:

cosmosException

getLink

public static String getLink(CosmosAsyncContainer cosmosAsyncContainer)

Parameters:

cosmosAsyncContainer

getLSN

public static long <E>getLSN(E e)

Parameters:

e

getMetaDataDiagnosticContext

public static MetadataDiagnosticsContext getMetaDataDiagnosticContext(CosmosDiagnostics cosmosDiagnostics)

Parameters:

cosmosDiagnostics

getNetworkRequestTimeoutFromGatewayConnectionConfig

public static Duration getNetworkRequestTimeoutFromGatewayConnectionConfig(GatewayConnectionConfig gatewayConnectionConfig)

Parameters:

gatewayConnectionConfig

getOfferQuerySpecFromResourceId

public static SqlQuerySpec getOfferQuerySpecFromResourceId(CosmosAsyncContainer container, String resourceId)

Parameters:

container
resourceId

getPartitionKey

public static PartitionKey getPartitionKey(PartitionKeyInternal partitionKeyInternal)

Parameters:

partitionKeyInternal

getPartitionKeyInternal

public static PartitionKeyInternal getPartitionKeyInternal(PartitionKey partitionKey)

Parameters:

partitionKey

getPartitionKeyRangeId

public static String <E>getPartitionKeyRangeId(E e)

Parameters:

e

getProperties

public static InternalObjectNode <T>getProperties(CosmosItemResponse<T> cosmosItemResponse)

Parameters:

cosmosItemResponse

getRegionsContacted

public static Set<String> getRegionsContacted(CosmosDiagnostics cosmosDiagnostics)

Parameters:

cosmosDiagnostics

getRequestBodyLength

public static int <E>getRequestBodyLength(E e)

Parameters:

e

getRequestHeaders

public static Map<String,String> <E>getRequestHeaders(CosmosException cosmosException)

Parameters:

cosmosException

getRequestTimeline

public static RequestTimeline <E>getRequestTimeline(E e)

Parameters:

e

getResourceAddress

public static String <E>getResourceAddress(E e)

Parameters:

e

getRetryContext

public static RetryContext getRetryContext(CosmosDiagnostics cosmosDiagnostics)

Parameters:

cosmosDiagnostics

getRntbdRequestLength

public static int <E>getRntbdRequestLength(E e)

Parameters:

e

getRntbdResponseLength

public static int <E>getRntbdResponseLength(E e)

Parameters:

e

getSerializationDiagnosticsContext

public static SerializationDiagnosticsContext getSerializationDiagnosticsContext(CosmosDiagnostics cosmosDiagnostics)

Parameters:

cosmosDiagnostics

getServiceEndpoint

public static String getServiceEndpoint(CosmosAsyncClient cosmosAsyncClient)

Parameters:

cosmosAsyncClient

getServiceEndpointStatistics

public static RntbdEndpointStatistics <E>getServiceEndpointStatistics(E e)

Parameters:

e

hasSendingRequestStarted

public static boolean <E>hasSendingRequestStarted(E e)

Parameters:

e

initializeAllAccessors

public static void initializeAllAccessors()

injectConfigs

public static CosmosClientBuilder injectConfigs(CosmosClientBuilder cosmosClientBuilder, Configs configs)

Parameters:

cosmosClientBuilder
configs

isEnableMultipleWriteLocations

public static boolean isEnableMultipleWriteLocations(DatabaseAccount account)

Parameters:

account

monitorTelemetry

public static void monitorTelemetry(MeterRegistry registry)

Parameters:

registry

noChanges

public static boolean <T>noChanges(FeedResponse<T> page)

Parameters:

page

putQueryMetricsIntoMap

public static void <T>putQueryMetricsIntoMap(FeedResponse<T> response, String partitionKeyRangeId, QueryMetrics queryMetrics)

Parameters:

response
partitionKeyRangeId
queryMetrics

queryMetricsFromFeedResponse

public static ConcurrentMap<String,QueryMetrics> <T>queryMetricsFromFeedResponse(FeedResponse<T> feedResponse)

Parameters:

feedResponse

recordAddressResolutionStart

public static String recordAddressResolutionStart(CosmosDiagnostics cosmosDiagnostics, URI targetEndpoint, boolean forceRefresh, boolean forceCollectionRoutingMapRefresh)

Parameters:

cosmosDiagnostics
targetEndpoint
forceRefresh
forceCollectionRoutingMapRefresh

recordGatewayResponse

public static void recordGatewayResponse(CosmosDiagnostics cosmosDiagnostics, RxDocumentServiceRequest rxDocumentServiceRequest, CosmosException cosmosException, GlobalEndpointManager globalEndpointManager)

Parameters:

cosmosDiagnostics
rxDocumentServiceRequest
cosmosException
globalEndpointManager

recordGatewayResponse

public static void recordGatewayResponse(CosmosDiagnostics cosmosDiagnostics, RxDocumentServiceRequest rxDocumentServiceRequest, StoreResponse storeResponse, GlobalEndpointManager globalEndpointManager)

Parameters:

cosmosDiagnostics
rxDocumentServiceRequest
storeResponse
globalEndpointManager

recordResponse

public static void recordResponse(CosmosDiagnostics cosmosDiagnostics, RxDocumentServiceRequest request, StoreResult storeResult, GlobalEndpointManager globalEndpointManager)

Parameters:

cosmosDiagnostics
request
storeResult
globalEndpointManager

recordRetryContextEndTime

public static void recordRetryContextEndTime(CosmosDiagnostics cosmosDiagnostics)

Parameters:

cosmosDiagnostics

setAltLink

public static void setAltLink(Resource resource, String altLink)

Parameters:

resource
altLink

setChannelAcquisitionTimeline

public static E <E>setChannelAcquisitionTimeline(E e, RntbdChannelAcquisitionTimeline channelAcquisitionTimeline)

Parameters:

e
channelAcquisitionTimeline

setContactedReplicas

public static void setContactedReplicas(CosmosDiagnostics cosmosDiagnostics, List<URI> contactedReplicas)

Parameters:

cosmosDiagnostics
contactedReplicas

setCosmosDiagnostics

public static CosmosException setCosmosDiagnostics(CosmosException cosmosException, CosmosDiagnostics cosmosDiagnostics)

Parameters:

cosmosException
cosmosDiagnostics

setFeedResponseDiagnostics

public static void setFeedResponseDiagnostics(CosmosDiagnostics cosmosDiagnostics, ConcurrentMap<String,QueryMetrics> queryMetricsMap)

Parameters:

cosmosDiagnostics
queryMetricsMap

setLSN

public static E <E>setLSN(E e, long lsn)

Parameters:

e
lsn

setMaxReplicaSetSize

public static void setMaxReplicaSetSize(ReplicationPolicy replicationPolicy, int value)

Parameters:

replicationPolicy
value

setPartitionKeyRangeId

public static E <E>setPartitionKeyRangeId(E e, String partitionKeyRangeId)

Parameters:

e
partitionKeyRangeId

setQueryPlanDiagnosticsContext

public static void setQueryPlanDiagnosticsContext(CosmosDiagnostics cosmosDiagnostics, QueryInfo.QueryPlanDiagnosticsContext diagnosticsContext)

Parameters:

cosmosDiagnostics
diagnosticsContext

setRequestBodyLength

public static E <E>setRequestBodyLength(E e, int requestLen)

Parameters:

e
requestLen

setRequestHeaders

public static void <E>setRequestHeaders(CosmosException cosmosException, Map<String,String> requestHeaders)

Parameters:

cosmosException
requestHeaders

setRequestTimeline

public static E <E>setRequestTimeline(E e, RequestTimeline requestTimeline)

Parameters:

e
requestTimeline

setResourceAddress

public static E <E>setResourceAddress(E e, String resourceAddress)

Parameters:

e
resourceAddress

setRntbdRequestLength

public static E <E>setRntbdRequestLength(E e, int requestLen)

Parameters:

e
requestLen

setRntbdResponseLength

public static E <E>setRntbdResponseLength(E e, int requestLen)

Parameters:

e
requestLen

setSendingRequestStarted

public static void <E>setSendingRequestStarted(E e, boolean hasSendingRequestStarted)

Parameters:

e
hasSendingRequestStarted

setServiceEndpointStatistics

public static E <E>setServiceEndpointStatistics(E e, RntbdEndpointStatistics rntbdEndpointStatistics)

Parameters:

e
rntbdEndpointStatistics

setSubStatusCode

public static void setSubStatusCode(CosmosException documentClientException, int subStatusCode)

Parameters:

documentClientException
subStatusCode

toFeedResponsePage

public static FeedResponse<T> <T>toFeedResponsePage(List<T> results, Map<String,String> headers, boolean noChanges, CosmosDiagnostics diagnostics)

Parameters:

results
headers
noChanges
diagnostics

toResourceResponse

public static ResourceResponse<T> <T>toResourceResponse(RxDocumentServiceResponse response, Class<T> cls)

Parameters:

response
cls

toStoredProcedureResponse

public static StoredProcedureResponse toStoredProcedureResponse(RxDocumentServiceResponse response)

Parameters:

response

Applies to