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

Class GatewayServiceConfigurationReader

java.lang.Object

com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayServiceConfigurationReader

public class GatewayServiceConfigurationReader
extends Object

This class will read the service configuration from the gateway. As .Net does code sharing between the SDK and GW there are two implementation to IServiceConfigurationReader GatewayServiceConfigurationReader which is for SDK DatabaseAccountConfigurationReader which is for GW Some of the APIs are not relevant in SDK and due to that in .Net the SDK implementation one throws not-implemented. In java, as we don't do code sharing and we got rid of the interface which is not needed and only implemented the methods in GatewayServiceConfigurationReader

Field Summary

Fields

Modifier and Type	Field	Description
static String	GATEWAY_READER_NOT_INITIALIZED
com.microsoft.azure.cosmosdb.ReplicationPolicy	userReplicationPolicy

Constructor Summary

Constructors

Constructor	Description
GatewayServiceConfigurationReader(URI serviceEndpoint, boolean hasResourceToken, String resourceToken, com.microsoft.azure.cosmosdb.ConnectionPolicy connectionPolicy, com.microsoft.azure.cosmosdb.internal.BaseAuthorizationTokenProvider baseAuthorizationTokenProvider, io.reactivex.netty.protocol.http.client.CompositeHttpClient<io.netty.buffer.ByteBuf,io.netty.buffer.ByteBuf> httpClient)

Method Summary

Modifier and Type	Method	Description
boolean	enableAuthorization()
com.microsoft.azure.cosmosdb.ConsistencyLevel	getDefaultConsistencyLevel()
Map<String,Object>	getQueryEngineConfiguration()
com.microsoft.azure.cosmosdb.ReplicationPolicy	getSystemReplicationPolicy()
com.microsoft.azure.cosmosdb.ReplicationPolicy	getUserReplicationPolicy()
rx.Single<com.microsoft.azure.cosmosdb.DatabaseAccount>	initializeReaderAsync()
void	setDefaultConsistencyLevel(com.microsoft.azure.cosmosdb.ConsistencyLevel value)

Methods inherited from class java.lang.Object

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

Field Detail

GATEWAY_READER_NOT_INITIALIZED

public static final String GATEWAY_READER_NOT_INITIALIZED

See Also:

Constant Field Values

userReplicationPolicy

public com.microsoft.azure.cosmosdb.ReplicationPolicy userReplicationPolicy

Constructor Detail

GatewayServiceConfigurationReader

public GatewayServiceConfigurationReader(URI serviceEndpoint,
                                         boolean hasResourceToken,
                                         String resourceToken,
                                         com.microsoft.azure.cosmosdb.ConnectionPolicy connectionPolicy,
                                         com.microsoft.azure.cosmosdb.internal.BaseAuthorizationTokenProvider baseAuthorizationTokenProvider,
                                         io.reactivex.netty.protocol.http.client.CompositeHttpClient<io.netty.buffer.ByteBuf,io.netty.buffer.ByteBuf> httpClient)

Method Detail

getUserReplicationPolicy

public com.microsoft.azure.cosmosdb.ReplicationPolicy getUserReplicationPolicy()

getSystemReplicationPolicy

public com.microsoft.azure.cosmosdb.ReplicationPolicy getSystemReplicationPolicy()

enableAuthorization

public boolean enableAuthorization()

getDefaultConsistencyLevel

public com.microsoft.azure.cosmosdb.ConsistencyLevel getDefaultConsistencyLevel()

setDefaultConsistencyLevel

public void setDefaultConsistencyLevel(com.microsoft.azure.cosmosdb.ConsistencyLevel value)

getQueryEngineConfiguration

public Map<String,Object> getQueryEngineConfiguration()

initializeReaderAsync

public rx.Single<com.microsoft.azure.cosmosdb.DatabaseAccount> initializeReaderAsync()