Uses of Class
dev.failsafe.spi.ExecutionResult

Packages that use ExecutionResult

Package	Description
dev.failsafe	APIs for performing failsafe executions.
dev.failsafe.internal
dev.failsafe.spi	The Failsafe Service Provider Interface (SPI).

Uses of ExecutionResult in dev.failsafe

Fields in dev.failsafe declared as ExecutionResult

Modifier and Type	Field	Description
private final ExecutionResult<R>	ExecutionImpl.previousResult
(package private) ExecutionResult<R>	ExecutionImpl.result

Fields in dev.failsafe with type parameters of type ExecutionResult

Modifier and Type	Field	Description
(package private) final BiConsumer<ExecutionResult<R>,ExecutionContext<R>>	FailsafeExecutor.completionHandler
private Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	AsyncExecutionImpl.outerFn
private Function<SyncExecutionInternal<R>,ExecutionResult<R>>	SyncExecutionImpl.outerFn

Methods in dev.failsafe that return ExecutionResult

Modifier and Type	Method	Description
ExecutionResult<R>	ExecutionImpl.getResult()
(package private) ExecutionResult<R>	ExecutionImpl.postExecute(ExecutionResult<R> result)	Externally called.
(package private) ExecutionResult<R>	SyncExecutionImpl.postExecute(ExecutionResult<R> result)

Methods in dev.failsafe that return types with arguments of type ExecutionResult

Modifier and Type	Method	Description
(package private) static <R> Function<SyncExecutionImpl<R>,ExecutionResult<R>>	Functions.get(ContextualSupplier<R,R> supplier, Executor executor)	Returns a Supplier for synchronous executions that pre-executes the execution, applies the supplier, records the result and returns the result.
(package private) static <R> Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	Functions.getPromise(ContextualSupplier<R,R> supplier, Executor executor)	Returns a Function for asynchronous executions that pre-executes the execution, applies the supplier, records the result and returns a promise containing the result.
(package private) static <R> Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	Functions.getPromiseExecution(AsyncRunnable<R> runnable, Executor executor)	Returns a Function for asynchronous executions that pre-executes the execution, runs the runnable, and attempts to complete the execution if a failure occurs.
(package private) static <R> Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	Functions.getPromiseOfStage(ContextualSupplier<R,? extends CompletionStage<? extends R>> supplier, FailsafeFuture<R> future, Executor executor)	Returns a Function that for asynchronous executions that pre-executes the execution, applies the supplier, records the result and returns a promise containing the result.
(package private) static <R> Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	Functions.toAsync(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)	Returns a Function that asynchronously applies the innerFn on the first call, synchronously on subsequent calls, and returns a promise containing the result.
(package private) static <R> Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	Functions.toExecutionAware(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn)	Returns a Function that returns an execution result if one was previously recorded, else applies the innerFn.

Methods in dev.failsafe with parameters of type ExecutionResult

Modifier and Type	Method	Description
private void	AsyncExecutionImpl.complete(ExecutionResult<R> result, Throwable error)
(package private) ExecutionResult<R>	ExecutionImpl.postExecute(ExecutionResult<R> result)	Externally called.
(package private) ExecutionResult<R>	SyncExecutionImpl.postExecute(ExecutionResult<R> result)
void	ExecutionImpl.record(ExecutionResult<R> result)

Method parameters in dev.failsafe with type arguments of type ExecutionResult

Modifier and Type	Method	Description
private <T> CompletableFuture<T>	FailsafeExecutor.callAsync(Function<FailsafeFuture<T>,Function<AsyncExecutionInternal<T>,CompletableFuture<ExecutionResult<T>>>> innerFn, boolean asyncExecution)	Calls the asynchronous innerFn via the configured Scheduler, handling results according to the configured policies.
(package private) static <R> Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	Functions.toAsync(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)	Returns a Function that asynchronously applies the innerFn on the first call, synchronously on subsequent calls, and returns a promise containing the result.
(package private) static <R> Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	Functions.toExecutionAware(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn)	Returns a Function that returns an execution result if one was previously recorded, else applies the innerFn.

Constructors in dev.failsafe with parameters of type ExecutionResult

Modifier	Constructor	Description
(package private)	ExecutionImpl(ExecutionResult<R> previousResult)	Used for testing purposes only

Constructor parameters in dev.failsafe with type arguments of type ExecutionResult

Modifier	Constructor	Description
(package private)	AsyncExecutionImpl(List<Policy<R>> policies, Scheduler scheduler, FailsafeFuture<R> future, boolean asyncExecution, Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn)
(package private)	SyncExecutionImpl(FailsafeExecutor<R> executor, Scheduler scheduler, CallImpl<R> call, Function<SyncExecutionInternal<R>,ExecutionResult<R>> innerFn)	Create a sync execution for the executor.

Uses of ExecutionResult in dev.failsafe.internal

Methods in dev.failsafe.internal that return ExecutionResult

Modifier and Type	Method	Description
protected ExecutionResult<R>	BulkheadExecutor.onFailure(ExecutionContext<R> context, ExecutionResult<R> result)
protected ExecutionResult<R>	CircuitBreakerExecutor.onFailure(ExecutionContext<R> context, ExecutionResult<R> result)
ExecutionResult<R>	RetryPolicyExecutor.onFailure(ExecutionContext<R> context, ExecutionResult<R> result)
protected ExecutionResult<R>	BulkheadExecutor.preExecute()
protected ExecutionResult<R>	CircuitBreakerExecutor.preExecute()
protected ExecutionResult<R>	RateLimiterExecutor.preExecute()

Methods in dev.failsafe.internal that return types with arguments of type ExecutionResult

Modifier and Type	Method	Description
Function<SyncExecutionInternal<R>,ExecutionResult<R>>	FallbackExecutor.apply(Function<SyncExecutionInternal<R>,ExecutionResult<R>> innerFn, Scheduler scheduler)	Performs an execution by calling pre-execute else calling the supplier, applying a fallback if it fails, and calling post-execute.
Function<SyncExecutionInternal<R>,ExecutionResult<R>>	RetryPolicyExecutor.apply(Function<SyncExecutionInternal<R>,ExecutionResult<R>> innerFn, Scheduler scheduler)
Function<SyncExecutionInternal<R>,ExecutionResult<R>>	TimeoutExecutor.apply(Function<SyncExecutionInternal<R>,ExecutionResult<R>> innerFn, Scheduler scheduler)	Schedules a separate timeout call that fails with TimeoutExceededException if the policy's timeout is exceeded.
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	FallbackExecutor.applyAsync(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)	Performs an async execution by calling pre-execute else calling the supplier and doing a post-execute.
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	RetryPolicyExecutor.applyAsync(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	TimeoutExecutor.applyAsync(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)	Schedules a separate timeout call that blocks and fails with TimeoutExceededException if the policy's timeout is exceeded.
CompletableFuture<ExecutionResult<R>>	RetryPolicyExecutor.onFailureAsync(ExecutionContext<R> context, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future)	Defaults async executions to not be complete until says they are.
protected CompletableFuture<ExecutionResult<R>>	BulkheadExecutor.preExecuteAsync(Scheduler scheduler, FailsafeFuture<R> future)
protected CompletableFuture<ExecutionResult<R>>	RateLimiterExecutor.preExecuteAsync(Scheduler scheduler, FailsafeFuture<R> future)

Methods in dev.failsafe.internal with parameters of type ExecutionResult

Modifier and Type	Method	Description
void	EventHandler.handle(ExecutionResult<R> result, ExecutionContext<R> context)
boolean	TimeoutExecutor.isFailure(ExecutionResult<R> result)
(package private) boolean	RetryPolicyExecutor.isValidResult(ExecutionResult<R> result, Throwable error, CompletableFuture<ExecutionResult<R>> promise)	Completes the promise and returns false if the result or error are invalid, else returns true.
protected ExecutionResult<R>	BulkheadExecutor.onFailure(ExecutionContext<R> context, ExecutionResult<R> result)
protected ExecutionResult<R>	CircuitBreakerExecutor.onFailure(ExecutionContext<R> context, ExecutionResult<R> result)
ExecutionResult<R>	RetryPolicyExecutor.onFailure(ExecutionContext<R> context, ExecutionResult<R> result)
CompletableFuture<ExecutionResult<R>>	RetryPolicyExecutor.onFailureAsync(ExecutionContext<R> context, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future)	Defaults async executions to not be complete until says they are.
void	BulkheadExecutor.onSuccess(ExecutionResult<R> result)
void	CircuitBreakerExecutor.onSuccess(ExecutionResult<R> result)

Method parameters in dev.failsafe.internal with type arguments of type ExecutionResult

Modifier and Type	Method	Description
Function<SyncExecutionInternal<R>,ExecutionResult<R>>	FallbackExecutor.apply(Function<SyncExecutionInternal<R>,ExecutionResult<R>> innerFn, Scheduler scheduler)	Performs an execution by calling pre-execute else calling the supplier, applying a fallback if it fails, and calling post-execute.
Function<SyncExecutionInternal<R>,ExecutionResult<R>>	RetryPolicyExecutor.apply(Function<SyncExecutionInternal<R>,ExecutionResult<R>> innerFn, Scheduler scheduler)
Function<SyncExecutionInternal<R>,ExecutionResult<R>>	TimeoutExecutor.apply(Function<SyncExecutionInternal<R>,ExecutionResult<R>> innerFn, Scheduler scheduler)	Schedules a separate timeout call that fails with TimeoutExceededException if the policy's timeout is exceeded.
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	FallbackExecutor.applyAsync(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)	Performs an async execution by calling pre-execute else calling the supplier and doing a post-execute.
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	RetryPolicyExecutor.applyAsync(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	TimeoutExecutor.applyAsync(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)	Schedules a separate timeout call that blocks and fails with TimeoutExceededException if the policy's timeout is exceeded.
Object	RetryPolicyExecutor.handleAsync(AsyncExecutionInternal<R> execution, Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future, CompletableFuture<ExecutionResult<R>> promise, AtomicReference<ExecutionResult<R>> previousResultRef)
Object	RetryPolicyExecutor.handleAsync(AsyncExecutionInternal<R> execution, Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future, CompletableFuture<ExecutionResult<R>> promise, AtomicReference<ExecutionResult<R>> previousResultRef)
Object	RetryPolicyExecutor.handleAsync(AsyncExecutionInternal<R> execution, Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future, CompletableFuture<ExecutionResult<R>> promise, AtomicReference<ExecutionResult<R>> previousResultRef)
(package private) boolean	RetryPolicyExecutor.isValidResult(ExecutionResult<R> result, Throwable error, CompletableFuture<ExecutionResult<R>> promise)	Completes the promise and returns false if the result or error are invalid, else returns true.

Uses of ExecutionResult in dev.failsafe.spi

Fields in dev.failsafe.spi declared as ExecutionResult

Modifier and Type	Field	Description
private static final ExecutionResult<?>	ExecutionResult.NONE

Fields in dev.failsafe.spi with type parameters of type ExecutionResult

Modifier and Type	Field	Description
private Map<Integer,BiConsumer<Boolean,ExecutionResult<R>>>	FailsafeFuture.cancelFunctions
private final BiConsumer<ExecutionResult<R>,ExecutionContext<R>>	FailsafeFuture.completionHandler

Methods in dev.failsafe.spi that return ExecutionResult

Modifier and Type	Method	Description
static <R> ExecutionResult<R>	ExecutionResult.exception(Throwable exception)	Returns an ExecutionResult with the exception set, complete true and success false.
ExecutionResult<R>	ExecutionInternal.getResult()	Returns the recorded result for an execution attempt.
static <R> ExecutionResult<R>	ExecutionResult.none()	Returns an execution that was completed with a non-result.
protected ExecutionResult<R>	PolicyExecutor.onFailure(ExecutionContext<R> context, ExecutionResult<R> result)	Performs post-execution handling for a result that is considered a failure according to PolicyExecutor.isFailure(ExecutionResult), possibly creating a new result, else returning the original result.
ExecutionResult<R>	PolicyExecutor.postExecute(ExecutionInternal<R> execution, ExecutionResult<R> result)	Performs synchronous post-execution handling for a result.
protected ExecutionResult<R>	PolicyExecutor.preExecute()	Called before execution to return an alternative result or exception such as if execution is not allowed or needed.
static <R> ExecutionResult<R>	ExecutionResult.success(R result)	Returns an ExecutionResult with the result set, complete true and success true.
ExecutionResult<R>	ExecutionResult.with(long delayNanos, boolean complete, boolean success)	Returns a copy of the ExecutionResult with the delayNanos, complete and success values.
ExecutionResult<R>	ExecutionResult.withDelay(long delayNanos)	Returns a copy of the ExecutionResult with the delayNanos value.
ExecutionResult<R>	ExecutionResult.withException()	Returns a copy of the ExecutionResult with success value of {code false}.
ExecutionResult<R>	ExecutionResult.withNonResult()	Returns a copy of the ExecutionResult with a non-result, and complete and success set to true.
ExecutionResult<R>	ExecutionResult.withNotComplete()	Returns a copy of the ExecutionResult with complete set to false, else this if nothing has changed.
ExecutionResult<R>	ExecutionResult.withResult(R result)	Returns a copy of the ExecutionResult with the result value, and complete and success set to true.
ExecutionResult<R>	ExecutionResult.withSuccess()	Returns a copy of the ExecutionResult with the complete and success values of true.

Methods in dev.failsafe.spi that return types with arguments of type ExecutionResult

Modifier and Type	Method	Description
Function<SyncExecutionInternal<R>,ExecutionResult<R>>	PolicyExecutor.apply(Function<SyncExecutionInternal<R>,ExecutionResult<R>> innerFn, Scheduler scheduler)	Performs an execution by calling pre-execute else calling the supplier and doing a post-execute.
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	PolicyExecutor.applyAsync(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)	Performs an async execution by calling pre-execute else calling the supplier and doing a post-execute.
static <R> CompletableFuture<ExecutionResult<R>>	ExecutionResult.nullFuture()	Returns a CompletableFuture that is completed with null.
protected CompletableFuture<ExecutionResult<R>>	PolicyExecutor.onFailureAsync(ExecutionContext<R> context, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future)	Performs potentially asynchrononus post-execution handling for a failed result, possibly creating a new result, else returning the original result.
protected CompletableFuture<ExecutionResult<R>>	PolicyExecutor.postExecuteAsync(AsyncExecutionInternal<R> execution, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future)	Performs potentially asynchronous post-execution handling for a result.
protected CompletableFuture<ExecutionResult<R>>	PolicyExecutor.preExecuteAsync(Scheduler scheduler, FailsafeFuture<R> future)	Called before an async execution to return an alternative result or exception such as if execution is not allowed or needed.

Methods in dev.failsafe.spi with parameters of type ExecutionResult

Modifier and Type	Method	Description
void	FailsafeFuture.cancelDependencies(PolicyExecutor<R> cancellingPolicyExecutor, boolean mayInterrupt, ExecutionResult<R> cancelResult)	Applies any cancel functions with the cancelResult for PolicyExecutors whose policyIndex is invalid input: '<' the policyIndex of the cancellingPolicyExecutor.
boolean	FailsafeFuture.completeResult(ExecutionResult<R> result)	Completes the execution with the result and calls the completion handler.
private void	PolicyExecutor.handleFailure(ExecutionResult<R> result, ExecutionContext<R> context)
private void	PolicyExecutor.handleSuccess(ExecutionResult<R> result, ExecutionContext<R> context)
protected boolean	PolicyExecutor.isFailure(ExecutionResult<R> result)	Returns whether the result is a success according to the policy.
protected ExecutionResult<R>	PolicyExecutor.onFailure(ExecutionContext<R> context, ExecutionResult<R> result)	Performs post-execution handling for a result that is considered a failure according to PolicyExecutor.isFailure(ExecutionResult), possibly creating a new result, else returning the original result.
protected CompletableFuture<ExecutionResult<R>>	PolicyExecutor.onFailureAsync(ExecutionContext<R> context, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future)	Performs potentially asynchrononus post-execution handling for a failed result, possibly creating a new result, else returning the original result.
protected void	PolicyExecutor.onSuccess(ExecutionResult<R> result)	Performs post-execution handling for a result that is considered a success according to PolicyExecutor.isFailure(ExecutionResult).
ExecutionResult<R>	PolicyExecutor.postExecute(ExecutionInternal<R> execution, ExecutionResult<R> result)	Performs synchronous post-execution handling for a result.
protected CompletableFuture<ExecutionResult<R>>	PolicyExecutor.postExecuteAsync(AsyncExecutionInternal<R> execution, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future)	Performs potentially asynchronous post-execution handling for a result.
void	ExecutionInternal.record(ExecutionResult<R> result)	Records the result if the execution has been pre-executed and a result has not already been recorded.

Method parameters in dev.failsafe.spi with type arguments of type ExecutionResult

Modifier and Type	Method	Description
Function<SyncExecutionInternal<R>,ExecutionResult<R>>	PolicyExecutor.apply(Function<SyncExecutionInternal<R>,ExecutionResult<R>> innerFn, Scheduler scheduler)	Performs an execution by calling pre-execute else calling the supplier and doing a post-execute.
Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>>	PolicyExecutor.applyAsync(Function<AsyncExecutionInternal<R>,CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)	Performs an async execution by calling pre-execute else calling the supplier and doing a post-execute.
void	FailsafeFuture.setCancelFn(int policyIndex, BiConsumer<Boolean,ExecutionResult<R>> cancelFn)	Sets a cancelFn to be called when a PolicyExecutor cancels dependencies with a policyIndex > the given policyIndex, or when this future is cancelled.
void	FailsafeFuture.setCancelFn(PolicyExecutor<R> policyExecutor, BiConsumer<Boolean,ExecutionResult<R>> cancelFn)	Sets a cancelFn to be called when a PolicyExecutor cancels dependencies with a policyIndex > the policyIndex of the given policyExecutor, or when this future is cancelled.

Constructor parameters in dev.failsafe.spi with type arguments of type ExecutionResult

Modifier	Constructor	Description
	FailsafeFuture(BiConsumer<ExecutionResult<R>,ExecutionContext<R>> completionHandler)