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 and Description
static String	GATEWAY_READER_NOT_INITIALIZED
ReplicationPolicy	userReplicationPolicy

Constructor Summary

Constructors

Constructor and Description
GatewayServiceConfigurationReader(URI serviceEndpoint, boolean hasResourceToken, String resourceToken, 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 and Description
boolean	enableAuthorization()
ConsistencyLevel	getDefaultConsistencyLevel()
Map<String,Object>	getQueryEngineConfiguration()
ReplicationPolicy	getSystemReplicationPolicy()
ReplicationPolicy	getUserReplicationPolicy()
rx.Single<DatabaseAccount>	initializeReaderAsync()
void	setDefaultConsistencyLevel(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 ReplicationPolicy userReplicationPolicy

Constructor Detail

GatewayServiceConfigurationReader

public GatewayServiceConfigurationReader(URI serviceEndpoint,
                                         boolean hasResourceToken,
                                         String resourceToken,
                                         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 ReplicationPolicy getUserReplicationPolicy()

getSystemReplicationPolicy

public ReplicationPolicy getSystemReplicationPolicy()

enableAuthorization

public boolean enableAuthorization()

getDefaultConsistencyLevel

public ConsistencyLevel getDefaultConsistencyLevel()

setDefaultConsistencyLevel

public void setDefaultConsistencyLevel(ConsistencyLevel value)

getQueryEngineConfiguration

public Map<String,Object> getQueryEngineConfiguration()

initializeReaderAsync

public rx.Single<DatabaseAccount> initializeReaderAsync()