com.microsoft.azure.cosmosdb.internal.directconnectivity

Class RntbdTransportClient

java.lang.Object

com.microsoft.azure.cosmosdb.internal.directconnectivity.TransportClient

com.microsoft.azure.cosmosdb.internal.directconnectivity.RntbdTransportClient

All Implemented Interfaces:

AutoCloseable

public final class RntbdTransportClient
extends TransportClient
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RntbdTransportClient.Options

Method Summary

Modifier and Type	Method and Description
void	close()
int	endpointCount()
int	endpointEvictionCount()
long	id()
rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse>	invokeStoreAsync(com.microsoft.azure.cosmosdb.internal.directconnectivity.Uri address, ResourceOperation unused, com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request)
boolean	isClosed()
io.micrometer.core.instrument.Tag	tag()
String	toString()

Methods inherited from class com.microsoft.azure.cosmosdb.internal.directconnectivity.TransportClient

invokeResourceOperationAsync

Methods inherited from class java.lang.Object

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

Method Detail

isClosed

public boolean isClosed()

close

public void close()

Specified by:

close in interface AutoCloseable

endpointCount

public int endpointCount()

endpointEvictionCount

public int endpointEvictionCount()

id

public long id()

invokeStoreAsync

public rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse> invokeStoreAsync(com.microsoft.azure.cosmosdb.internal.directconnectivity.Uri address,
                                                                                                          ResourceOperation unused,
                                                                                                          com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request)

Specified by:

invokeStoreAsync in class TransportClient

tag

public io.micrometer.core.instrument.Tag tag()

toString

public String toString()

Overrides:

toString in class Object