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

Class RntbdRequestArgs

java.lang.Object

com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestArgs

public final class RntbdRequestArgs
extends Object

Constructor Summary

Constructors

Constructor and Description
RntbdRequestArgs(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest serviceRequest, URI physicalAddress)

Method Summary

Modifier and Type	Method and Description
UUID	activityId()
Duration	lifetime()
long	nanoTimeCreated()
String	origin()
URI	physicalAddress()
String	replicaPath()
com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest	serviceRequest()
long	stop(io.micrometer.core.instrument.Timer requests, io.micrometer.core.instrument.Timer responses)
OffsetDateTime	timeCreated()
String	toString()
void	traceOperation(org.slf4j.Logger logger, io.netty.channel.ChannelHandlerContext context, String operationName, Object... args)
long	transportRequestId()

Methods inherited from class java.lang.Object

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

Constructor Detail

RntbdRequestArgs

public RntbdRequestArgs(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest serviceRequest,
                        URI physicalAddress)

Method Detail

activityId

public UUID activityId()

lifetime

public Duration lifetime()

nanoTimeCreated

public long nanoTimeCreated()

origin

public String origin()

physicalAddress

public URI physicalAddress()

replicaPath

public String replicaPath()

serviceRequest

public com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest serviceRequest()

timeCreated

public OffsetDateTime timeCreated()

transportRequestId

public long transportRequestId()

stop

public long stop(io.micrometer.core.instrument.Timer requests,
                 io.micrometer.core.instrument.Timer responses)

toString

public String toString()

Overrides:

toString in class Object

traceOperation

public void traceOperation(org.slf4j.Logger logger,
                           io.netty.channel.ChannelHandlerContext context,
                           String operationName,
                           Object... args)