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

Class QuorumReader

java.lang.Object

com.microsoft.azure.cosmosdb.internal.directconnectivity.QuorumReader

public class QuorumReader
extends Object

QuorumReader wraps the client side quorum logic on top of the StoreReader

Constructor Summary

Constructors

Constructor	Description
QuorumReader(TransportClient transportClient, AddressSelector addressSelector, StoreReader storeReader, GatewayServiceConfigurationReader serviceConfigReader, com.microsoft.azure.cosmosdb.rx.internal.IAuthorizationTokenProvider authorizationTokenProvider, com.microsoft.azure.cosmosdb.rx.internal.Configs configs)
QuorumReader(com.microsoft.azure.cosmosdb.rx.internal.Configs configs, TransportClient transportClient, AddressSelector addressSelector, StoreReader storeReader, GatewayServiceConfigurationReader serviceConfigReader, com.microsoft.azure.cosmosdb.rx.internal.IAuthorizationTokenProvider authorizationTokenProvider)

Method Summary

Modifier and Type	Method	Description
rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse>	readStrongAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest entity, int readQuorumValue, ReadMode readMode)

Methods inherited from class java.lang.Object

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

Constructor Detail

QuorumReader

public QuorumReader(com.microsoft.azure.cosmosdb.rx.internal.Configs configs,
                    TransportClient transportClient,
                    AddressSelector addressSelector,
                    StoreReader storeReader,
                    GatewayServiceConfigurationReader serviceConfigReader,
                    com.microsoft.azure.cosmosdb.rx.internal.IAuthorizationTokenProvider authorizationTokenProvider)

QuorumReader

public QuorumReader(TransportClient transportClient,
                    AddressSelector addressSelector,
                    StoreReader storeReader,
                    GatewayServiceConfigurationReader serviceConfigReader,
                    com.microsoft.azure.cosmosdb.rx.internal.IAuthorizationTokenProvider authorizationTokenProvider,
                    com.microsoft.azure.cosmosdb.rx.internal.Configs configs)

Method Detail

readStrongAsync

public rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse> readStrongAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest entity,
                                                                                                         int readQuorumValue,
                                                                                                         ReadMode readMode)