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()
long	creationTime()
boolean	expire()
Duration	lifetime()
io.netty.util.Timeout	newTimeout(io.netty.util.TimerTask task)
RntbdRequestRecord.Stage	stage()
RntbdRequestRecord	stage(RntbdRequestRecord.Stage value)
long	stop(io.micrometer.core.instrument.Timer requests, io.micrometer.core.instrument.Timer responses)
long	timeoutIntervalInMillis()
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()

creationTime

public long creationTime()

expire

public boolean expire()

lifetime

public Duration lifetime()

newTimeout

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

stage

public RntbdRequestRecord.Stage stage()

stage

public RntbdRequestRecord stage(RntbdRequestRecord.Stage value)

timeoutIntervalInMillis

public long timeoutIntervalInMillis()

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 CompletableFuture<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse>