applySessionToken(RxDocumentServiceRequest) | | 0% | | 0% | 16 | 16 | 22 | 22 | 1 | 1 |
lambda$toDocumentServiceResponse$3(RxDocumentServiceRequest, HttpRequest, Throwable) | | 0% | | 0% | 10 | 10 | 27 | 27 | 1 | 1 |
lambda$applySessionToken$9(RxDocumentServiceRequest, Map, Utils.ValueHolder, Utils.ValueHolder) | | 0% | | 0% | 8 | 8 | 28 | 28 | 1 | 1 |
validateOrThrow(RxDocumentServiceRequest, HttpResponseStatus, HttpHeaders, byte[]) | | 0% | | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
RxGatewayStoreModel(DiagnosticsClientContext, ISessionContainer, ConsistencyLevel, QueryCompatibilityMode, UserAgentContainer, GlobalEndpointManager, HttpClient, ApiType) | | 0% | | 0% | 4 | 4 | 20 | 20 | 1 | 1 |
getHttpRequestHeaders(Map) | | 0% | | 0% | 6 | 6 | 12 | 12 | 1 | 1 |
invokeAsyncInternal(RxDocumentServiceRequest) | | 0% | | 0% | 11 | 11 | 13 | 13 | 1 | 1 |
lambda$processMessage$5(RxDocumentServiceRequest, Throwable) | | 0% | | 0% | 8 | 8 | 14 | 14 | 1 | 1 |
performRequestInternal(RxDocumentServiceRequest, HttpMethod, URI) | | 0% | | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
lambda$toDocumentServiceResponse$0(HttpResponse, RxDocumentServiceRequest, int, HttpHeaders, byte[]) | | 0% | | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
getUri(RxDocumentServiceRequest) | | 0% | | 0% | 4 | 4 | 12 | 12 | 1 | 1 |
captureSessionTokenAndHandlePartitionSplit(RxDocumentServiceRequest, Map) | | 0% | | 0% | 5 | 5 | 8 | 8 | 1 | 1 |
performRequest(RxDocumentServiceRequest, HttpMethod) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
lambda$applySessionToken$10(RxDocumentServiceRequest, Map, Utils.ValueHolder) | | 0% | | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
query(RxDocumentServiceRequest) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
captureSessionToken(RxDocumentServiceRequest, Map) | | 0% | | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
addIntendedCollectionRid(RxDocumentServiceRequest) | | 0% | | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
lambda$toDocumentServiceResponse$1(RxDocumentServiceRequest, HttpResponse) | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
lambda$addIntendedCollectionRid$8(RxDocumentServiceRequest, Utils.ValueHolder) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
lambda$toDocumentServiceResponse$2(HttpRequest, StoreResponse) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
ensureSlashPrefixed(String) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
processMessage(RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
toDocumentServiceResponse(Mono, RxDocumentServiceRequest, HttpRequest) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
invokeAsync(RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
isMasterOperation(ResourceType, OperationType) | | 0% | | 0% | 4 | 4 | 2 | 2 | 1 | 1 |
isStoredProcedureMasterOperation(ResourceType, OperationType) | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
lambda$processMessage$6(RxDocumentServiceRequest, RxDocumentServiceResponse) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
addIntendedCollectionRidAndSessionToken(RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
create(RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
patch(RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
upsert(RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
read(RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
replace(RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
delete(RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
deleteByPartitionKey(RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
execute(RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
readFeed(RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$invokeAsync$4(RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setGatewayServiceConfigurationReader(GatewayServiceConfigurationReader) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setPartitionKeyRangeCache(RxPartitionKeyRangeCache) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setUseMultipleWriteLocations(boolean) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setCollectionCache(RxClientCollectionCache) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
static {...} | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isUseMultipleWriteLocations() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPartitionKeyRangeCache() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getGatewayServiceConfigurationReader() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCollectionCache() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$captureSessionTokenAndHandlePartitionSplit$7(Utils.ValueHolder) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
enableThroughputControl(ThroughputControlStore) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |