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

Class RntbdRequestRecord

java.lang.Object

java.util.concurrent.CompletableFuture<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse>

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

All Implemented Interfaces:

CompletionStage<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse>, Future<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse>

public final class RntbdRequestRecord
extends CompletableFuture<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RntbdRequestRecord.Stage

Nested classes/interfaces inherited from class java.util.concurrent.CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Constructor Summary

Constructors

Constructor and Description
RntbdRequestRecord(RntbdRequestArgs args, RntbdRequestTimer timer)

Method Summary

Modifier and Type	Method and Description
UUID	activityId()
RntbdRequestArgs	args()
boolean	expire()
Duration	lifetime()
io.netty.util.Timeout	newTimeout(io.netty.util.TimerTask task)
int	requestLength()
int	responseLength()
RntbdRequestRecord.Stage	stage()
RntbdRequestRecord	stage(RntbdRequestRecord.Stage value)
long	stop(io.micrometer.core.instrument.Timer requests, io.micrometer.core.instrument.Timer responses)
RequestTimeline	takeTimelineSnapshot()
OffsetDateTime	timeCompleted()
OffsetDateTime	timeCreated()
OffsetDateTime	timePipelined()
OffsetDateTime	timeQueued()
OffsetDateTime	timeReceived()
OffsetDateTime	timeSent()
String	toString()
long	transportRequestId()

Methods inherited from class java.util.concurrent.CompletableFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, cancel, complete, completedFuture, completeExceptionally, exceptionally, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, obtrudeException, obtrudeValue, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAsync, runAsync, supplyAsync, supplyAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, whenComplete, whenCompleteAsync, whenCompleteAsync

Methods inherited from class java.lang.Object

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

Constructor Detail

RntbdRequestRecord

public RntbdRequestRecord(RntbdRequestArgs args,
                          RntbdRequestTimer timer)

Method Detail

activityId

public UUID activityId()

args

public RntbdRequestArgs args()

lifetime

public Duration lifetime()

requestLength

public int requestLength()

responseLength

public int responseLength()

stage

public RntbdRequestRecord.Stage stage()

stage

public RntbdRequestRecord stage(RntbdRequestRecord.Stage value)

timeCompleted

public OffsetDateTime timeCompleted()

timeCreated

public OffsetDateTime timeCreated()

timePipelined

public OffsetDateTime timePipelined()

timeQueued

public OffsetDateTime timeQueued()

timeReceived

public OffsetDateTime timeReceived()

timeSent

public OffsetDateTime timeSent()

transportRequestId

public long transportRequestId()

expire

public boolean expire()

newTimeout

public io.netty.util.Timeout newTimeout(io.netty.util.TimerTask task)

takeTimelineSnapshot

public RequestTimeline takeTimelineSnapshot()

stop

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

toString

public String toString()

Overrides:

toString in class CompletableFuture<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse>