A B C D E F G H I J L M N O P Q R S T U V W
All Classes All Packages

A

acceptOutboundMessage(Object) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestEncoder

Returns true if the given message is an RntbdRequestRecord instance.

acquire(Promise<Channel>) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

activityId() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContext

activityId() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestArgs

activityId() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

add(MeterRegistry) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

AddressResolver - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

Abstracts out the logic to resolve physical replica addresses for the given RxDocumentServiceRequest

AddressResolver() - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.AddressResolver

AddressSelector - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

AddressSelector(IAddressResolver, Protocol) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.AddressSelector

allocator() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

Any - com.microsoft.azure.cosmosdb.internal.directconnectivity.ReadMode

args() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

B

BarrierRequestHelper - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

BarrierRequestHelper() - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.BarrierRequestHelper

bind(ChannelHandlerContext, SocketAddress, ChannelPromise) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

Called once a bind operation is made.

BoundedStaleness - com.microsoft.azure.cosmosdb.internal.directconnectivity.ReadMode

bufferPageSize() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

bufferPageSize() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options

bufferPageSize(int) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

build() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

Builder(int) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

Builder(Duration) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

C

channelAcquired(Channel) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelHandler

Called by ChannelPool.acquire() after a Channel is acquired

channelActive(ChannelHandlerContext) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

The Channel of the ChannelHandlerContext is now active

channelCreated(Channel) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelHandler

Called by ChannelPool.release(io.netty.channel.Channel) after a Channel is created

channelInactive(ChannelHandlerContext) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

The Channel of the ChannelHandlerContext was registered and has reached the end of its lifetime

channelRead(ChannelHandlerContext, Object) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextRequestDecoder

Prepare for decoding an @{link RntbdContextRequest} or fire a channel readTree event to pass the input message along

channelRead(ChannelHandlerContext, Object) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestDecoder

Prepare for decoding an @{link RntbdRequest} or fire a channel readTree event to pass the input message along.

channelRead(ChannelHandlerContext, Object) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

The Channel of the ChannelHandlerContext has read a message from its peer.

channelReadComplete(ChannelHandlerContext) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

The Channel of the ChannelHandlerContext has fully consumed the most-recent message read.

channelRegistered(ChannelHandlerContext) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

Constructs a CoalescingBufferQueue for buffering encoded requests until we have an RntbdRequest

channelReleased(Channel) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelHandler

Called by ChannelPool.release(io.netty.channel.Channel) after a Channel is released

channelsAcquired() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

channelsAcquired() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint

channelsAcquired() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

channelsAcquired() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint

channelsAvailable() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

channelsAvailable() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint

channelsAvailable() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

channelsAvailable() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint

channelUnregistered(ChannelHandlerContext) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

The Channel of the ChannelHandlerContext was unregistered from its EventLoop

channelWritabilityChanged(ChannelHandlerContext) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

Gets called once the writable state of a Channel changed.

clientVersion() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContext

close() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.HttpTransportClient

close() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

close() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint

close() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Provider

close() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestTimer

close() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint

close() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint.Provider

close() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient

close() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreClientFactory

close(ChannelHandlerContext, ChannelPromise) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

Called once a close operation is made.

com.microsoft.azure.cosmosdb.internal - package com.microsoft.azure.cosmosdb.internal

com.microsoft.azure.cosmosdb.internal.directconnectivity - package com.microsoft.azure.cosmosdb.internal.directconnectivity

com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd - package com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

com.microsoft.azure.cosmosdb.internal.routing - package com.microsoft.azure.cosmosdb.internal.routing

Completed - com.microsoft.azure.cosmosdb.internal.FanoutOperationState

Fanout operation completed

COMPLETED - com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord.Stage

completionRate() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

Computes the number of successful (non-error) responses received divided by the number of completed requests.

concurrentRequests() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint

concurrentRequests() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

concurrentRequests() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint

config() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Provider

config() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint.Provider

Config(RntbdTransportClient.Options, SslContext, LogLevel) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

ConflictException - Exception in com.microsoft.azure.cosmosdb.internal.directconnectivity

While this class is public, but it is not part of our published public APIs.

ConflictException() - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ConflictException

ConflictException(Error, long, String, Map<String, String>) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ConflictException

ConflictException(Error, Map<String, String>) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ConflictException

ConflictException(Exception) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ConflictException

ConflictException(String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ConflictException

ConflictException(String, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ConflictException

ConflictException(String, Exception, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ConflictException

ConflictException(String, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ConflictException

connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

Called once a connect operation is made.

connectionTimeout() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options

connectionTimeout(Duration) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

connectionTimeoutInMillis() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

ConsistencyReader - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

ConsistencyReader has a dependency on both StoreReader and QuorumReader.

ConsistencyReader(Configs, AddressSelector, ISessionContainer, TransportClient, GatewayServiceConfigurationReader, IAuthorizationTokenProvider) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.ConsistencyReader

ConsistencyWriter - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

ConsistencyWriter(AddressSelector, ISessionContainer, TransportClient, IAuthorizationTokenProvider, GatewayServiceConfigurationReader, boolean) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.ConsistencyWriter

ContentSerializationFormat - Enum in com.microsoft.azure.cosmosdb.internal

CosmosBinary - com.microsoft.azure.cosmosdb.internal.ContentSerializationFormat

Custom binary for Cosmos DB that encodes a superset of JSON values.

count() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Provider

count() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint.Provider

createAsync(RxDocumentServiceRequest, IAuthorizationTokenProvider, Long, Long) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.BarrierRequestHelper

createPartitionKeyInternal(String) - Static method in class com.microsoft.azure.cosmosdb.internal.routing.PartitionKeyInternalUtils

createStoreClient(IAddressResolver, SessionContainer, GatewayServiceConfigurationReader, IAuthorizationTokenProvider, boolean) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreClientFactory

CustomHeaders - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

CustomHeaders() - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.CustomHeaders

CustomHeaders.HttpHeaders - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

D

decode(byte[]) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdUUID

Decode a UUID as serialized by Microsoft APIs like System.Guid.ToByteArray

decode(ByteBuf) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContext

decode(ByteBuf) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextRequest

decode(ByteBuf) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequest

decode(ByteBuf) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdUUID

Decode a UUID as serialized by Microsoft APIs like System.Guid.ToByteArray

decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextRequestDecoder

Decode an RntbdContextRequest from an ByteBuf stream

decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestDecoder

Decode the input ByteBuf to an RntbdRequest instance.

decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponseDecoder

Deserialize from an input ByteBuf to an RntbdResponse instance.

deregister(ChannelHandlerContext, ChannelPromise) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

Called once a deregister operation is made from the current registered EventLoop.

disconnect(ChannelHandlerContext, ChannelPromise) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

Called once a disconnect operation is made.

dispose() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayAddressCache

E

EffectivePartitionKey - com.microsoft.azure.cosmosdb.internal.ReadFeedKeyType

Use effective partition key

empty() - Static method in class com.microsoft.azure.cosmosdb.internal.RequestTimeline

Returns an empty RequestTimeline.

EMPTY - Static variable in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdUUID

enableAuthorization() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayServiceConfigurationReader

encode(ByteBuf) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContext

encode(ByteBuf) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextRequest

encode(ByteBuf) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

Serializes the current response to the given byte buffer.

encode(ChannelHandlerContext, RntbdRequestRecord, ByteBuf) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestEncoder

Encode a message into a ByteBuf

encode(UUID) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdUUID

Encodes a UUID as serialized by Microsoft APIs like System.Guid.ToByteArray

encode(UUID, ByteBuf) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdUUID

Encodes a UUID as serialized by Microsoft APIs like System.Guid.ToByteArray

endpointCount() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient

endpointEvictionCount() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient

endpoints() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

EnumerationDirection - Enum in com.microsoft.azure.cosmosdb.internal

ErrorUtils - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

ErrorUtils() - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.ErrorUtils

Event(String, OffsetDateTime, OffsetDateTime) - Constructor for class com.microsoft.azure.cosmosdb.internal.RequestTimeline.Event

evictions() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Provider

evictions() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint.Provider

exceptionCaught(ChannelHandlerContext, Throwable) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

Processes ChannelHandlerContext.fireExceptionCaught(Throwable) in the ChannelPipeline

EXCLUDE_SYSTEM_PROPERTIES - Static variable in class com.microsoft.azure.cosmosdb.internal.directconnectivity.CustomHeaders.HttpHeaders

expire() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

F

FanoutOperationState - Enum in com.microsoft.azure.cosmosdb.internal

flush(ChannelHandlerContext) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

Called once a flush operation is made

ForbiddenException - Exception in com.microsoft.azure.cosmosdb.internal.directconnectivity

ForbiddenException() - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ForbiddenException

ForbiddenException(Error, long, String, Map<String, String>) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ForbiddenException

ForbiddenException(Exception) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ForbiddenException

ForbiddenException(String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ForbiddenException

ForbiddenException(String, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ForbiddenException

ForbiddenException(String, HttpResponseHeaders, URI) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ForbiddenException

ForbiddenException(String, Exception, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ForbiddenException

Forward - com.microsoft.azure.cosmosdb.internal.EnumerationDirection

Use forward direction

Freeze - com.microsoft.azure.cosmosdb.internal.MigrateCollectionDirective

Move to HDD

from(RntbdContextRequest, ServerProperties, HttpResponseStatus) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContext

from(RntbdRequestArgs) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequest

G

GATEWAY_READER_NOT_INITIALIZED - Static variable in class com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayServiceConfigurationReader

GatewayAddressCache - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

GatewayAddressCache(URL, Protocol, IAuthorizationTokenProvider, UserAgentContainer, CompositeHttpClient<ByteBuf, ByteBuf>) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayAddressCache

GatewayAddressCache(URL, Protocol, IAuthorizationTokenProvider, UserAgentContainer, CompositeHttpClient<ByteBuf, ByteBuf>, long) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayAddressCache

GatewayServiceConfigurationReader - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

This class will read the service configuration from the gateway.

GatewayServiceConfigurationReader(URI, boolean, String, ConnectionPolicy, BaseAuthorizationTokenProvider, CompositeHttpClient<ByteBuf, ByteBuf>) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayServiceConfigurationReader

get(URI) - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Provider

get(URI) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint.Provider

getActivityId() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextRequest

getActivityId() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequest

getActivityId() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

getAgent() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ServerProperties

getClientVersion() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextRequest

GetConsistencyLevelToUse(GatewayServiceConfigurationReader, RxDocumentServiceRequest) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestHelper

getContent() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

getDefaultConsistencyLevel() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayServiceConfigurationReader

getDuration() - Method in class com.microsoft.azure.cosmosdb.internal.RequestTimeline.Event

getError() - Method in exception com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextException

getErrorFromStream(Observable<ByteBuf>, int) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ErrorUtils

getErrorResponseAsync(HttpClientResponse<ByteBuf>) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ErrorUtils

getHeader(RntbdConstants.RntbdRequestHeader) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequest

getHeader(RntbdConstants.RntbdResponseHeader) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

Returns the value of the given response header.

getHeaders() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

getMaxReplicaSetSize(RxDocumentServiceRequest) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ConsistencyReader

getMessageLength() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

getMinReplicaSetSize(RxDocumentServiceRequest) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ConsistencyReader

getName() - Method in class com.microsoft.azure.cosmosdb.internal.RequestTimeline.Event

getPrimaryUri(RxDocumentServiceRequest, List<AddressInformation>) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.AddressSelector

getQueryEngineConfiguration() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayServiceConfigurationReader

getRequestTimeout(TimeUnit) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestTimer

getResponseHeaders() - Method in exception com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextException

getStatus() - Method in exception com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextException

getStatus() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

getStatusCode() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContext

getSystemReplicationPolicy() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayServiceConfigurationReader

getTime() - Method in class com.microsoft.azure.cosmosdb.internal.RequestTimeline.Event

getTransportRequestId() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequest

getTransportRequestId() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

getUnauthenticatedTimeoutInSeconds() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContext

getUserReplicationPolicy() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayServiceConfigurationReader

getVersion() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ServerProperties

GoneAndRetryWithRetryPolicy - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

GoneAndRetryWithRetryPolicy(RxDocumentServiceRequest, Integer) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.GoneAndRetryWithRetryPolicy

H

handlerAdded(ChannelHandlerContext) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

Gets called after the ChannelHandler was added to the actual context and it's ready to handle events.

handlerRemoved(ChannelHandlerContext) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

Gets called after the ChannelHandler was removed from the actual context and it doesn't handle events anymore.

hasPayload() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

Returns true if this response has a payload.

HttpClientUtils - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

HttpClientUtils() - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.HttpClientUtils

HttpHeaders() - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.CustomHeaders.HttpHeaders

HttpTransportClient - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

HttpTransportClient(Configs, int, UserAgentContainer) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.HttpTransportClient

I

IAddressCache - Interface in com.microsoft.azure.cosmosdb.internal.directconnectivity

IAddressResolver - Interface in com.microsoft.azure.cosmosdb.internal.directconnectivity

id() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint

id() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint

id() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient

idleChannelTimeout() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options

idleChannelTimeout(Duration) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

idleConnectionTimeout() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelHealthChecker

idleConnectionTimeoutInNanos() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

idleEndpointTimeout() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options

idleEndpointTimeout(Duration) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

idleEndpointTimeoutInNanos() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

idleTimeoutInSeconds() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContext

initChannel(Channel) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelHandler

Called by @{ChannelPipeline} initializer after the current channel is registered to an event loop.

INITIAL_ARGUMENT_VALUE_POLICY_ARG - Static variable in class com.microsoft.azure.cosmosdb.internal.directconnectivity.GoneAndRetryWithRetryPolicy

initializeCaches(RxCollectionCache, ICollectionRoutingMapCache, IAddressCache) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.AddressResolver

initializeReaderAsync() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayServiceConfigurationReader

invokeAsync(RxDocumentServiceRequest, Func1<RxDocumentServiceRequest, Single<RxDocumentServiceRequest>>) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ReplicatedResourceClient

invokeResourceOperationAsync(Uri, RxDocumentServiceRequest) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.TransportClient

invokeStoreAsync(Uri, ResourceOperation, RxDocumentServiceRequest) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.HttpTransportClient

invokeStoreAsync(Uri, ResourceOperation, RxDocumentServiceRequest) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient

invokeStoreAsync(Uri, ResourceOperation, RxDocumentServiceRequest) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.TransportClient

isClosed() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

isClosed() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint

isClosed() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint

isClosed() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient

isGlobalStrongEnabled() - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ReplicatedResourceClient

isHealthy(Channel) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelHealthChecker

isMasterResource(ResourceType) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ReplicatedResourceClient

isReadingFromMaster(ResourceType, OperationType) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ReplicatedResourceClient

IStoreClient - Interface in com.microsoft.azure.cosmosdb.internal.directconnectivity

iterator() - Method in class com.microsoft.azure.cosmosdb.internal.RequestTimeline

Returns an iterator for enumerating the RequestTimeline.Event instances in this RequestTimeline.

J

JsonText - com.microsoft.azure.cosmosdb.internal.ContentSerializationFormat

Standard JSON RFC UTF-8 text

L

lastRequestTime() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint

lifetime() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestArgs

lifetime() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

list() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Provider

list() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint.Provider

LockedException - Exception in com.microsoft.azure.cosmosdb.internal.directconnectivity

While this class is public, but it is not part of our published public APIs.

LockedException() - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.LockedException

LockedException(Error, long, String, Map<String, String>) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.LockedException

LockedException(Exception) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.LockedException

LockedException(String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.LockedException

LockedException(String, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.LockedException

LockedException(String, Exception, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.LockedException

LockedException(String, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.LockedException

logException(String, String) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ErrorUtils

logException(URI, String) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ErrorUtils

logGoneException(String, String) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ErrorUtils

logGoneException(URI, String) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ErrorUtils

M

markComplete(RntbdRequestRecord) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

maxBufferCapacity() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

maxBufferCapacity() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options

maxBufferCapacity(int) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

maxChannels() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

maxChannelsPerEndpoint() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

maxChannelsPerEndpoint() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options

maxChannelsPerEndpoint(int) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

maxRequestsPerChannel() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

maxRequestsPerChannel() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

maxRequestsPerChannel() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options

maxRequestsPerChannel(int) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

MethodNotAllowedException - Exception in com.microsoft.azure.cosmosdb.internal.directconnectivity

MethodNotAllowedException() - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.MethodNotAllowedException

MethodNotAllowedException(Error, long, String, Map<String, String>) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.MethodNotAllowedException

MethodNotAllowedException(Exception) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.MethodNotAllowedException

MethodNotAllowedException(String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.MethodNotAllowedException

MethodNotAllowedException(String, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.MethodNotAllowedException

MethodNotAllowedException(String, HttpResponseHeaders, URI) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.MethodNotAllowedException

MethodNotAllowedException(String, Exception, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.MethodNotAllowedException

MigrateCollectionDirective - Enum in com.microsoft.azure.cosmosdb.internal

N

nanoTimeCreated() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestArgs

newTimeout(TimerTask) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

newTimeout(TimerTask) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestTimer

NotSpecified - com.microsoft.azure.cosmosdb.internal.RemoteStorageType

Use standard storage

O

of() - Static method in class com.microsoft.azure.cosmosdb.internal.RequestTimeline

Returns an empty RequestTimeline.

of(RequestTimeline.Event) - Static method in class com.microsoft.azure.cosmosdb.internal.RequestTimeline

Returns a new RequestTimeline with a single event.

of(RequestTimeline.Event...) - Static method in class com.microsoft.azure.cosmosdb.internal.RequestTimeline

Returns a new RequestTimeline with an arbitrary number of events.

of(RequestTimeline.Event, RequestTimeline.Event) - Static method in class com.microsoft.azure.cosmosdb.internal.RequestTimeline

Returns a new RequestTimeline with a pair of events.

of(RequestTimeline.Event, RequestTimeline.Event, RequestTimeline.Event) - Static method in class com.microsoft.azure.cosmosdb.internal.RequestTimeline

Returns a new RequestTimeline with three events.

of(RequestTimeline.Event, RequestTimeline.Event, RequestTimeline.Event, RequestTimeline.Event) - Static method in class com.microsoft.azure.cosmosdb.internal.RequestTimeline

Returns a new RequestTimeline with four events.

of(RequestTimeline.Event, RequestTimeline.Event, RequestTimeline.Event, RequestTimeline.Event, RequestTimeline.Event) - Static method in class com.microsoft.azure.cosmosdb.internal.RequestTimeline

Returns a new RequestTimeline with five events.

offerChannel(Channel) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

Offer a Channel back to the internal storage

openAsync(DocumentCollection, List<PartitionKeyRangeIdentity>) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayAddressCache

operationType - Variable in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ResourceOperation

origin() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestArgs

P

parseResponseAsync(HttpClientResponse<ByteBuf>) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.HttpClientUtils

PartitionKeyInternalUtils - Class in com.microsoft.azure.cosmosdb.internal.routing

PartitionKeyInternalUtils() - Constructor for class com.microsoft.azure.cosmosdb.internal.routing.PartitionKeyInternalUtils

PartitionKeyRangeGoneException - Exception in com.microsoft.azure.cosmosdb.internal.directconnectivity

This exception is thrown when DocumentServiceRequest contains x-ms-documentdb-partitionkeyrangeid header and such range id doesn't exist.

PartitionKeyRangeGoneException() - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.PartitionKeyRangeGoneException

PartitionKeyRangeGoneException(Error, long, String, Map<String, String>) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.PartitionKeyRangeGoneException

PartitionKeyRangeGoneException(Exception) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.PartitionKeyRangeGoneException

PartitionKeyRangeGoneException(String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.PartitionKeyRangeGoneException

PartitionKeyRangeGoneException(String, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.PartitionKeyRangeGoneException

PartitionKeyRangeGoneException(String, Exception) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.PartitionKeyRangeGoneException

PartitionKeyRangeGoneException(String, Exception, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.PartitionKeyRangeGoneException

physicalAddress() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestArgs

PIPELINED - com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord.Stage

pollChannel() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

Poll a Channel out of internal storage to reuse it

PreconditionFailedException - Exception in com.microsoft.azure.cosmosdb.internal.directconnectivity

While this class is public, but it is not part of our published public APIs.

PreconditionFailedException() - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.PreconditionFailedException

PreconditionFailedException(Error, long, String, Map<String, String>) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.PreconditionFailedException

PreconditionFailedException(Exception) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.PreconditionFailedException

PreconditionFailedException(String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.PreconditionFailedException

PreconditionFailedException(String, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.PreconditionFailedException

PreconditionFailedException(String, Exception, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.PreconditionFailedException

PreconditionFailedException(String, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.PreconditionFailedException

Premium - com.microsoft.azure.cosmosdb.internal.RemoteStorageType

Use premium storage

Primary - com.microsoft.azure.cosmosdb.internal.directconnectivity.ReadMode

processMessage(RxDocumentServiceRequest) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ServerStoreModel

processMessageAsync(RxDocumentServiceRequest) - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.IStoreClient

processMessageAsync(RxDocumentServiceRequest, IRetryPolicy) - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.IStoreClient

processMessageAsync(RxDocumentServiceRequest, IRetryPolicy, Func1<RxDocumentServiceRequest, Single<RxDocumentServiceRequest>>) - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.IStoreClient

processMessageAsync(RxDocumentServiceRequest, IRetryPolicy, Func1<RxDocumentServiceRequest, Single<RxDocumentServiceRequest>>) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreClient

processMessageAsync(RxDocumentServiceRequest, Func1<RxDocumentServiceRequest, Single<RxDocumentServiceRequest>>) - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.IStoreClient

protocolVersion() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContext

Provider(RntbdTransportClient, RntbdTransportClient.Options, SslContext) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint.Provider

Q

QueryRequestPerformanceActivity - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

QueryRequestPerformanceActivity() - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.QueryRequestPerformanceActivity

QUEUED - com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord.Stage

QuorumReader - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

QuorumReader wraps the client side quorum logic on top of the StoreReader

QuorumReader(TransportClient, AddressSelector, StoreReader, GatewayServiceConfigurationReader, IAuthorizationTokenProvider, Configs) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.QuorumReader

QuorumReader(Configs, TransportClient, AddressSelector, StoreReader, GatewayServiceConfigurationReader, IAuthorizationTokenProvider) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.QuorumReader

R

read(ChannelHandlerContext) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

Intercepts ChannelHandlerContext.read()

readAsync(RxDocumentServiceRequest, TimeoutHelper, boolean, boolean) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ConsistencyReader

readDelayLimit() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelHealthChecker

ReadFeedKeyType - Enum in com.microsoft.azure.cosmosdb.internal

Type of Start and End key for ReadFeedKey

ReadMode - Enum in com.microsoft.azure.cosmosdb.internal.directconnectivity

readMultipleReplicaAsync(RxDocumentServiceRequest, boolean, int, boolean, boolean, ReadMode) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreReader

readMultipleReplicaAsync(RxDocumentServiceRequest, boolean, int, boolean, boolean, ReadMode, boolean, boolean) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreReader

Makes requests to multiple replicas at once and returns responses

readPrimaryAsync(RxDocumentServiceRequest, boolean, boolean) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreReader

readStrongAsync(RxDocumentServiceRequest, int, ReadMode) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.QuorumReader

readValue(File, Class<T>) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdObjectMapper

readValue(InputStream, Class<T>) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdObjectMapper

readValue(String, Class<T>) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdObjectMapper

RECEIVED - com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord.Stage

receiveHangDetectionTime() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options

receiveHangDetectionTime(Duration) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

receiveHangDetectionTimeInNanos() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

refCnt() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

Returns the reference count of this object.

release() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

Decreases the reference count by 1.

release(int) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

Decreases the reference count by decrement and deallocates this response if the count reaches 0.

release(Channel, Promise<Void>) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

remoteAddress() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

remoteAddress() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint

remoteAddress() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint

RemoteStorageType - Enum in com.microsoft.azure.cosmosdb.internal

replicaPath() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestArgs

ReplicatedResourceClient - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

ReplicatedResourceClient uses the ConsistencyReader to make requests to backend

ReplicatedResourceClient(Configs, AddressSelector, ISessionContainer, TransportClient, GatewayServiceConfigurationReader, IAuthorizationTokenProvider, boolean, boolean) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.ReplicatedResourceClient

reportIssue(Logger, Object, String, Object...) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdReporter

reportIssueUnless(Logger, boolean, Object, String, Object...) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdReporter

request(RntbdRequestArgs) - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint

request(RntbdRequestArgs) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint

RequestEntityTooLargeException - Exception in com.microsoft.azure.cosmosdb.internal.directconnectivity

While this class is public, but it is not part of our published public APIs.

RequestEntityTooLargeException() - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestEntityTooLargeException

RequestEntityTooLargeException(Error, long, String, Map<String, String>) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestEntityTooLargeException

RequestEntityTooLargeException(Exception) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestEntityTooLargeException

RequestEntityTooLargeException(String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestEntityTooLargeException

RequestEntityTooLargeException(String, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestEntityTooLargeException

RequestEntityTooLargeException(String, Exception, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestEntityTooLargeException

RequestEntityTooLargeException(String, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestEntityTooLargeException

requestExpiryInterval() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options

requestExpiryInterval(Duration) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

RequestHelper - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

RequestHelper() - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestHelper

requestLength() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

requestQueueLength() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

requestQueueLength() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint

requestQueueLength() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

requestQueueLength() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint

RequestRateTooLargeException - Exception in com.microsoft.azure.cosmosdb.internal.directconnectivity

RequestRateTooLargeException() - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestRateTooLargeException

RequestRateTooLargeException(Error, long, String, Map<String, String>) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestRateTooLargeException

RequestRateTooLargeException(Exception) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestRateTooLargeException

RequestRateTooLargeException(String, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestRateTooLargeException

RequestRateTooLargeException(String, HttpResponseHeaders, URI) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestRateTooLargeException

RequestRateTooLargeException(String, Exception, HttpResponseHeaders, URI) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestRateTooLargeException

RequestRateTooLargeException(String, Exception, URI) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestRateTooLargeException

RequestRateTooLargeException(String, URI) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RequestRateTooLargeException

requests() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

requestSize() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

RequestTimeline - Class in com.microsoft.azure.cosmosdb.internal

Represents the time and duration of important events in the lifetime of a request.

RequestTimeline.Event - Class in com.microsoft.azure.cosmosdb.internal

requestTimeout() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options

requestTimeout(Duration) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

requestTimeoutInNanos() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

requestTimerResolution() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options

requestTimerResolution(Duration) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

requestTimerResolutionInNanos() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

resolveAddressesAsync(RxDocumentServiceRequest, boolean) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.AddressSelector

resolveAllUriAsync(RxDocumentServiceRequest, boolean, boolean) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.AddressSelector

resolveAsync(RxDocumentServiceRequest, boolean) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.AddressResolver

resolveAsync(RxDocumentServiceRequest, boolean) - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.IAddressResolver

resolvePrimaryUriAsync(RxDocumentServiceRequest, boolean) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.AddressSelector

ResourceId - com.microsoft.azure.cosmosdb.internal.ReadFeedKeyType

Use resource name

ResourceOperation - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

ResourceOperation(OperationType, ResourceType) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.ResourceOperation

resourceType - Variable in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ResourceOperation

responseErrors() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

responseLength() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

responseRate() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

Computes the number of successful (non-error) responses received divided by the number of requests sent

responseSize() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

responseSuccesses() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

retain() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

Increases the reference count by 1.

retain(int) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

Increases the reference count by the specified increment.

RetryWithException - Exception in com.microsoft.azure.cosmosdb.internal.directconnectivity

RetryWithException(Error, long, String, Map<String, String>) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RetryWithException

RetryWithException(String, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RetryWithException

RetryWithException(String, HttpResponseHeaders, URI) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RetryWithException

RetryWithException(String, Exception, HttpResponseHeaders, URI) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RetryWithException

RetryWithException(String, Exception, URI) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RetryWithException

RetryWithException(String, URI) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.RetryWithException

Reverse - com.microsoft.azure.cosmosdb.internal.EnumerationDirection

Use reverse direction

RntbdClientChannelHandler - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdClientChannelHealthChecker - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdClientChannelHealthChecker(RntbdEndpoint.Config) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelHealthChecker

RntbdClientChannelPool - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

ChannelPool implementation that enforces a maximum number of concurrent direct TCP Cosmos connections

RntbdContext - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdContextException - Exception in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdContextNegotiator - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdContextNegotiator(RntbdRequestManager, UserAgentContainer) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextNegotiator

RntbdContextRequest - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdContextRequestDecoder - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdContextRequestDecoder() - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextRequestDecoder

RntbdEndpoint - Interface in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdEndpoint.Config - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdEndpoint.Provider - Interface in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdMetrics - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdMetrics(RntbdTransportClient, RntbdEndpoint) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

RntbdObjectMapper - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdReporter - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdRequest - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdRequestArgs - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdRequestArgs(RxDocumentServiceRequest, URI) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestArgs

RntbdRequestDecoder - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdRequestDecoder() - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestDecoder

RntbdRequestEncoder - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdRequestEncoder() - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestEncoder

RntbdRequestFramer - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdRequestFramer() - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestFramer

RntbdRequestManager - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdRequestManager(ChannelHealthChecker, int) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

RntbdRequestRecord - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdRequestRecord(RntbdRequestArgs, RntbdRequestTimer) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

RntbdRequestRecord.Stage - Enum in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdRequestTimer - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdRequestTimer(long, long) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestTimer

RntbdResponse - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdResponse(UUID, int, Map<String, String>, ByteBuf) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

Initializes a new RntbdResponse instance.

RntbdResponseDecoder - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdResponseDecoder() - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponseDecoder

RntbdServiceEndpoint - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdServiceEndpoint.Provider - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

RntbdTransportClient - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

RntbdTransportClient.Options - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

RntbdTransportClient.Options.Builder - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

A builder for constructing RntbdTransportClient.Options instances.

RntbdUUID - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

S

sendHangDetectionTime() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options

sendHangDetectionTime(Duration) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

sendHangDetectionTimeInNanos() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

SENT - com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord.Stage

serverProperties() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContext

ServerProperties - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

ServerProperties(String, String) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.ServerProperties

ServerStoreModel - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

ServerStoreModel(StoreClient) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.ServerStoreModel

serverVersion() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContext

serviceRequest() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestArgs

ServiceUnavailableException - Exception in com.microsoft.azure.cosmosdb.internal.directconnectivity

ServiceUnavailableException() - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ServiceUnavailableException

ServiceUnavailableException(Error, long, String, Map<String, String>) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ServiceUnavailableException

ServiceUnavailableException(Exception) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ServiceUnavailableException

ServiceUnavailableException(String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ServiceUnavailableException

ServiceUnavailableException(String, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ServiceUnavailableException

ServiceUnavailableException(String, HttpResponseHeaders, URI) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ServiceUnavailableException

ServiceUnavailableException(String, Exception, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.ServiceUnavailableException

setDefaultConsistencyLevel(ConsistencyLevel) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayServiceConfigurationReader

shouldRetry(Exception) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.GoneAndRetryWithRetryPolicy

shutdownTimeout() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options

shutdownTimeout(Duration) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

shutdownTimeoutInNanos() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

sslContext() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

stage() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

stage(RntbdRequestRecord.Stage) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

Standard - com.microsoft.azure.cosmosdb.internal.RemoteStorageType

Use standard storage

Started - com.microsoft.azure.cosmosdb.internal.FanoutOperationState

Fanout operation started

status() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContext

stop(Timer, Timer) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestArgs

stop(Timer, Timer) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

StoreClient - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

Instantiated to issue direct connectivity requests to the backend on: - Gateway (for gateway mode clients) - Client (for direct mode clients) StoreClient uses the ReplicatedResourceClient to make requests to the backend.

StoreClient(Configs, IAddressResolver, SessionContainer, GatewayServiceConfigurationReader, IAuthorizationTokenProvider, TransportClient, boolean) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreClient

StoreClientFactory - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

StoreClientFactory(Configs, int, int, UserAgentContainer) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreClientFactory

StoreReader - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

StoreReader(TransportClient, AddressSelector, ISessionContainer) - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreReader

Strong - com.microsoft.azure.cosmosdb.internal.directconnectivity.ReadMode

T

tag() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint

tag() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint

tag() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient

tags() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

takeTimelineSnapshot() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

Thaw - com.microsoft.azure.cosmosdb.internal.MigrateCollectionDirective

Move to SSD

timeCompleted() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

timeCreated() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestArgs

timeCreated() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

timePipelined() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

timeQueued() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

timeReceived() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

timeSent() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

toJson(Object) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdObjectMapper

toString() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelHealthChecker

toString() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

toString() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContext

toString() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextRequest

toString() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

toString() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

toString() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestArgs

toString() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

toString() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

toString() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint

toString() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options

toString() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient

toString() - Method in class com.microsoft.azure.cosmosdb.internal.RequestTimeline

Returns a textual representation of this RequestTimeline.

toString(Object) - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdObjectMapper

touch() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

Records the current access location of this object for debugging purposes

touch(Object) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponse

Records the current access location of this object with additional arbitrary information for debugging purposes

traceOperation(Logger, ChannelHandlerContext, String, Object...) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestArgs

TransportClient - Class in com.microsoft.azure.cosmosdb.internal.directconnectivity

TransportClient() - Constructor for class com.microsoft.azure.cosmosdb.internal.directconnectivity.TransportClient

TransportException - Exception in com.microsoft.azure.cosmosdb.internal.directconnectivity

TransportException(String, Throwable) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.TransportException

transportRequestId() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestArgs

transportRequestId() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord

tryGetAddresses(RxDocumentServiceRequest, PartitionKeyRangeIdentity, boolean) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayAddressCache

tryGetAddresses(RxDocumentServiceRequest, PartitionKeyRangeIdentity, boolean) - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.IAddressCache

Resolves physical addresses by either PartitionKeyRangeIdentity.

U

UnauthorizedException - Exception in com.microsoft.azure.cosmosdb.internal.directconnectivity

UnauthorizedException() - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.UnauthorizedException

UnauthorizedException(Error, long, String, Map<String, String>) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.UnauthorizedException

UnauthorizedException(Exception) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.UnauthorizedException

UnauthorizedException(String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.UnauthorizedException

UnauthorizedException(String, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.UnauthorizedException

UnauthorizedException(String, HttpResponseHeaders, URI) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.UnauthorizedException

UnauthorizedException(String, Exception, HttpResponseHeaders, String) - Constructor for exception com.microsoft.azure.cosmosdb.internal.directconnectivity.UnauthorizedException

usedDirectMemory() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

usedDirectMemory() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint

usedDirectMemory() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

usedDirectMemory() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint

usedHeapMemory() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

usedHeapMemory() - Method in interface com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint

usedHeapMemory() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdMetrics

usedHeapMemory() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdServiceEndpoint

userAgent() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

userAgent() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options

userAgent(UserAgentContainer) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient.Options.Builder

userEventTriggered(ChannelHandlerContext, Object) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

Processes inbound events triggered by channel handlers in the RntbdClientChannelHandler pipeline

userReplicationPolicy - Variable in class com.microsoft.azure.cosmosdb.internal.directconnectivity.GatewayServiceConfigurationReader

V

valueOf(String) - Static method in enum com.microsoft.azure.cosmosdb.internal.ContentSerializationFormat

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.microsoft.azure.cosmosdb.internal.directconnectivity.ReadMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord.Stage

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.microsoft.azure.cosmosdb.internal.EnumerationDirection

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.microsoft.azure.cosmosdb.internal.FanoutOperationState

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.microsoft.azure.cosmosdb.internal.MigrateCollectionDirective

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.microsoft.azure.cosmosdb.internal.ReadFeedKeyType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.microsoft.azure.cosmosdb.internal.RemoteStorageType

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.microsoft.azure.cosmosdb.internal.ContentSerializationFormat

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.microsoft.azure.cosmosdb.internal.directconnectivity.ReadMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestRecord.Stage

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.microsoft.azure.cosmosdb.internal.EnumerationDirection

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.microsoft.azure.cosmosdb.internal.FanoutOperationState

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.microsoft.azure.cosmosdb.internal.MigrateCollectionDirective

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.microsoft.azure.cosmosdb.internal.ReadFeedKeyType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.microsoft.azure.cosmosdb.internal.RemoteStorageType

Returns an array containing the constants of this enum type, in the order they are declared.

W

wireLogLevel() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdEndpoint.Config

write(ChannelHandlerContext, Object, ChannelPromise) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextNegotiator

Called once a write operation is made.

write(ChannelHandlerContext, Object, ChannelPromise) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager

Called once a write operation is made

writeAsync(RxDocumentServiceRequest, TimeoutHelper, boolean) - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.ConsistencyWriter

writeDelayLimit() - Method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelHealthChecker

writer() - Static method in class com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdObjectMapper

A B C D E F G H I J L M N O P Q R S T U V W
All Classes All Packages