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 |