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

Class StoreReader

java.lang.Object

com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreReader

public class StoreReader
extends Object

Constructor Summary

Constructors

Constructor	Description
StoreReader(TransportClient transportClient, AddressSelector addressSelector, com.microsoft.azure.cosmosdb.ISessionContainer sessionContainer)

Method Summary

Modifier and Type	Method	Description
rx.Single<List<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResult>>	readMultipleReplicaAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest entity, boolean includePrimary, int replicaCountToRead, boolean requiresValidLsn, boolean useSessionToken, ReadMode readMode)
rx.Single<List<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResult>>	readMultipleReplicaAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest entity, boolean includePrimary, int replicaCountToRead, boolean requiresValidLsn, boolean useSessionToken, ReadMode readMode, boolean checkMinLSN, boolean forceReadAll)	Makes requests to multiple replicas at once and returns responses
rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResult>	readPrimaryAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest entity, boolean requiresValidLsn, boolean useSessionToken)

Methods inherited from class java.lang.Object

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

Constructor Detail

StoreReader

public StoreReader(TransportClient transportClient,
                   AddressSelector addressSelector,
                   com.microsoft.azure.cosmosdb.ISessionContainer sessionContainer)

Method Detail

readMultipleReplicaAsync

public rx.Single<List<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResult>> readMultipleReplicaAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest entity,
                                                                                                                      boolean includePrimary,
                                                                                                                      int replicaCountToRead,
                                                                                                                      boolean requiresValidLsn,
                                                                                                                      boolean useSessionToken,
                                                                                                                      ReadMode readMode)

readMultipleReplicaAsync

public rx.Single<List<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResult>> readMultipleReplicaAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest entity,
                                                                                                                      boolean includePrimary,
                                                                                                                      int replicaCountToRead,
                                                                                                                      boolean requiresValidLsn,
                                                                                                                      boolean useSessionToken,
                                                                                                                      ReadMode readMode,
                                                                                                                      boolean checkMinLSN,
                                                                                                                      boolean forceReadAll)

Makes requests to multiple replicas at once and returns responses

Parameters:

entity - RxDocumentServiceRequest

includePrimary - flag to indicate whether to indicate primary replica in the reads

replicaCountToRead - number of replicas to read from

requiresValidLsn - flag to indicate whether a valid lsn is required to consider a response as valid

useSessionToken - flag to indicate whether to use session token

readMode - Read mode

checkMinLSN - set minimum required session lsn

forceReadAll - reads from all available replicas to gather result from readsToRead number of replicas

Returns:

ReadReplicaResult which indicates the LSN and whether Quorum was Met / Not Met etc

readPrimaryAsync

public rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResult> readPrimaryAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest entity,
                                                                                                        boolean requiresValidLsn,
                                                                                                        boolean useSessionToken)