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 and Description
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(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 Summary

Modifier and Type	Method and 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)