Package org.apache.bookkeeper.client

Class SyncCallbackUtils.FutureReadLastConfirmed

java.lang.Object

java.util.concurrent.CompletableFuture<Long>

org.apache.bookkeeper.client.SyncCallbackUtils.FutureReadLastConfirmed

All Implemented Interfaces:

CompletionStage<Long>, Future<Long>, AsyncCallback.ReadLastConfirmedCallback

Enclosing class:

SyncCallbackUtils

static class SyncCallbackUtils.FutureReadLastConfirmed
extends CompletableFuture<Long>
implements AsyncCallback.ReadLastConfirmedCallback

Nested Class Summary

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

CompletableFuture.AsynchronousCompletionTask

Constructor Summary

Constructors

Constructor	Description
FutureReadLastConfirmed()

Method Summary

Modifier and Type	Method	Description
void	readLastConfirmedComplete(int rc, long lastConfirmed, Object ctx)	Callback definition for bookie recover operations.

Methods inherited from class java.util.concurrent.CompletableFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, cancel, complete, completeAsync, completeAsync, completedFuture, completedStage, completeExceptionally, completeOnTimeout, copy, defaultExecutor, delayedExecutor, delayedExecutor, exceptionally, exceptionallyAsync, exceptionallyAsync, exceptionallyCompose, exceptionallyComposeAsync, exceptionallyComposeAsync, failedFuture, failedStage, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeException, obtrudeValue, orTimeout, 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, toString, whenComplete, whenCompleteAsync, whenCompleteAsync

Methods inherited from class java.lang.Object

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

Constructor Details

FutureReadLastConfirmed

FutureReadLastConfirmed()

Method Details

readLastConfirmedComplete

public void readLastConfirmedComplete(int rc,
 long lastConfirmed,
 Object ctx)

Description copied from interface: AsyncCallback.ReadLastConfirmedCallback

Callback definition for bookie recover operations.

Specified by:

readLastConfirmedComplete in interface AsyncCallback.ReadLastConfirmedCallback

Parameters:

rc - Return code

lastConfirmed - The entry id of the last confirmed write or INVALID_ENTRY_ID if no entry has been confirmed

ctx - context object