Package com.microsoft.azure.cosmosdb.internal.directconnectivity

Class ReplicatedResourceClient

java.lang.Object

com.microsoft.azure.cosmosdb.internal.directconnectivity.ReplicatedResourceClient

public class ReplicatedResourceClient
extends Object

ReplicatedResourceClient uses the ConsistencyReader to make requests to backend

Constructor Summary

Constructors

Constructor

Description

ReplicatedResourceClient(com.microsoft.azure.cosmosdb.rx.internal.Configs configs, AddressSelector addressSelector, com.microsoft.azure.cosmosdb.ISessionContainer sessionContainer, TransportClient transportClient, GatewayServiceConfigurationReader serviceConfigReader, com.microsoft.azure.cosmosdb.rx.internal.IAuthorizationTokenProvider authorizationTokenProvider, boolean enableReadRequestsFallback, boolean useMultipleWriteLocations)

Method Summary

Modifier and Type	Method	Description
rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse>	invokeAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request, rx.functions.Func1<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest,rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest>> prepareRequestAsyncDelegate)
static boolean	isGlobalStrongEnabled()
static boolean	isMasterResource(com.microsoft.azure.cosmosdb.internal.ResourceType resourceType)
static boolean	isReadingFromMaster(com.microsoft.azure.cosmosdb.internal.ResourceType resourceType, com.microsoft.azure.cosmosdb.internal.OperationType operationType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReplicatedResourceClient

public ReplicatedResourceClient(com.microsoft.azure.cosmosdb.rx.internal.Configs configs,
                                AddressSelector addressSelector,
                                com.microsoft.azure.cosmosdb.ISessionContainer sessionContainer,
                                TransportClient transportClient,
                                GatewayServiceConfigurationReader serviceConfigReader,
                                com.microsoft.azure.cosmosdb.rx.internal.IAuthorizationTokenProvider authorizationTokenProvider,
                                boolean enableReadRequestsFallback,
                                boolean useMultipleWriteLocations)

Method Detail

isReadingFromMaster

public static boolean isReadingFromMaster(com.microsoft.azure.cosmosdb.internal.ResourceType resourceType,
                                          com.microsoft.azure.cosmosdb.internal.OperationType operationType)

isMasterResource

public static boolean isMasterResource(com.microsoft.azure.cosmosdb.internal.ResourceType resourceType)

isGlobalStrongEnabled

public static boolean isGlobalStrongEnabled()

invokeAsync

public rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse> invokeAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request,
                                                                                                     rx.functions.Func1<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest,rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest>> prepareRequestAsyncDelegate)