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/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)
long	stop(io.micrometer.core.instrument.Timer requests, io.micrometer.core.instrument.Timer responses)
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()

lifetime

public Duration lifetime()

transportRequestId

public long transportRequestId()

expire

public boolean expire()

newTimeout

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

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>