com.microsoft.azure.cosmosdb.internal.directconnectivity

Class AddressSelector

java.lang.Object

com.microsoft.azure.cosmosdb.internal.directconnectivity.AddressSelector

public class AddressSelector
extends Object

Constructor Summary

Constructors

Constructor and Description
AddressSelector(IAddressResolver addressResolver, com.microsoft.azure.cosmosdb.internal.directconnectivity.Protocol protocol)

Method Summary

Modifier and Type	Method and Description
static com.microsoft.azure.cosmosdb.internal.directconnectivity.Uri	getPrimaryUri(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request, List<com.microsoft.azure.cosmosdb.internal.directconnectivity.AddressInformation> replicaAddresses)
rx.Single<List<com.microsoft.azure.cosmosdb.internal.directconnectivity.AddressInformation>>	resolveAddressesAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request, boolean forceAddressRefresh)
rx.Single<List<com.microsoft.azure.cosmosdb.internal.directconnectivity.Uri>>	resolveAllUriAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request, boolean includePrimary, boolean forceRefresh)
rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.Uri>	resolvePrimaryUriAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request, boolean forceAddressRefresh)

Methods inherited from class java.lang.Object

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

Constructor Detail

AddressSelector

public AddressSelector(IAddressResolver addressResolver,
                       com.microsoft.azure.cosmosdb.internal.directconnectivity.Protocol protocol)

Method Detail

resolveAllUriAsync

public rx.Single<List<com.microsoft.azure.cosmosdb.internal.directconnectivity.Uri>> resolveAllUriAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request,
                                                                                                        boolean includePrimary,
                                                                                                        boolean forceRefresh)

resolvePrimaryUriAsync

public rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.Uri> resolvePrimaryUriAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request,
                                                                                                      boolean forceAddressRefresh)

getPrimaryUri

public static com.microsoft.azure.cosmosdb.internal.directconnectivity.Uri getPrimaryUri(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request,
                                                                                         List<com.microsoft.azure.cosmosdb.internal.directconnectivity.AddressInformation> replicaAddresses)
                                                                                  throws com.microsoft.azure.cosmosdb.internal.directconnectivity.GoneException

Throws:

com.microsoft.azure.cosmosdb.internal.directconnectivity.GoneException

resolveAddressesAsync

public rx.Single<List<com.microsoft.azure.cosmosdb.internal.directconnectivity.AddressInformation>> resolveAddressesAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request,
                                                                                                                          boolean forceAddressRefresh)