com.microsoft.azure.cosmosdb.internal.directconnectivity

Class GatewayAddressCache

java.lang.Object

com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayAddressCache

All Implemented Interfaces:

IAddressCache

public class GatewayAddressCache
extends Object
implements IAddressCache

Constructor Summary

Constructors

Constructor and Description
GatewayAddressCache(URL serviceEndpoint, com.microsoft.azure.cosmosdb.internal.directconnectivity.Protocol protocol, com.microsoft.azure.cosmosdb.rx.internal.IAuthorizationTokenProvider tokenProvider, com.microsoft.azure.cosmosdb.internal.UserAgentContainer userAgent, io.reactivex.netty.protocol.http.client.CompositeHttpClient<io.netty.buffer.ByteBuf,io.netty.buffer.ByteBuf> httpClient)
GatewayAddressCache(URL serviceEndpoint, com.microsoft.azure.cosmosdb.internal.directconnectivity.Protocol protocol, com.microsoft.azure.cosmosdb.rx.internal.IAuthorizationTokenProvider tokenProvider, com.microsoft.azure.cosmosdb.internal.UserAgentContainer userAgent, io.reactivex.netty.protocol.http.client.CompositeHttpClient<io.netty.buffer.ByteBuf,io.netty.buffer.ByteBuf> httpClient, long suboptimalPartitionForceRefreshIntervalInSeconds)

Method Summary

Modifier and Type	Method and Description
void	dispose()
rx.Completable	openAsync(DocumentCollection collection, List<com.microsoft.azure.cosmosdb.internal.routing.PartitionKeyRangeIdentity> partitionKeyRangeIdentities)
rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.AddressInformation[]>	tryGetAddresses(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request, com.microsoft.azure.cosmosdb.internal.routing.PartitionKeyRangeIdentity partitionKeyRangeIdentity, boolean forceRefreshPartitionAddresses) Resolves physical addresses by either PartitionKeyRangeIdentity.

Methods inherited from class java.lang.Object

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

Constructor Detail

GatewayAddressCache

public GatewayAddressCache(URL serviceEndpoint,
                           com.microsoft.azure.cosmosdb.internal.directconnectivity.Protocol protocol,
                           com.microsoft.azure.cosmosdb.rx.internal.IAuthorizationTokenProvider tokenProvider,
                           com.microsoft.azure.cosmosdb.internal.UserAgentContainer userAgent,
                           io.reactivex.netty.protocol.http.client.CompositeHttpClient<io.netty.buffer.ByteBuf,io.netty.buffer.ByteBuf> httpClient,
                           long suboptimalPartitionForceRefreshIntervalInSeconds)

GatewayAddressCache

public GatewayAddressCache(URL serviceEndpoint,
                           com.microsoft.azure.cosmosdb.internal.directconnectivity.Protocol protocol,
                           com.microsoft.azure.cosmosdb.rx.internal.IAuthorizationTokenProvider tokenProvider,
                           com.microsoft.azure.cosmosdb.internal.UserAgentContainer userAgent,
                           io.reactivex.netty.protocol.http.client.CompositeHttpClient<io.netty.buffer.ByteBuf,io.netty.buffer.ByteBuf> httpClient)

Method Detail

tryGetAddresses

public rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.AddressInformation[]> tryGetAddresses(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request,
                                                                                                                com.microsoft.azure.cosmosdb.internal.routing.PartitionKeyRangeIdentity partitionKeyRangeIdentity,
                                                                                                                boolean forceRefreshPartitionAddresses)

Description copied from interface: IAddressCache

Resolves physical addresses by either PartitionKeyRangeIdentity.

Specified by:

tryGetAddresses in interface IAddressCache

Parameters:

request - Request is needed only by GatewayAddressCache in the only case when request is name based and user has name based auth token. PartitionkeyRangeIdentity can be used to locate auth token in this case.

partitionKeyRangeIdentity - target partition key range Id

forceRefreshPartitionAddresses - Whether addresses need to be refreshed as previously resolved addresses were determined to be outdated.

Returns:

Physical addresses.

dispose

public void dispose()

openAsync

public rx.Completable openAsync(DocumentCollection collection,
                                List<com.microsoft.azure.cosmosdb.internal.routing.PartitionKeyRangeIdentity> partitionKeyRangeIdentities)