Interface RetryingExecutor<ResponseT> (2.21.0)

Version 2.21.0

• 2.59.0 (latest)
• 2.58.0
• 2.57.0
• 2.55.0
• 2.54.1
• 2.53.0
• 2.52.0
• 2.51.0
• 2.50.0
• 2.49.0
• 2.48.1
• 2.47.0
• 2.46.1
• 2.45.0
• 2.43.0
• 2.42.0
• 2.41.0
• 2.39.0
• 2.38.0
• 2.37.0
• 2.36.0
• 2.35.0
• 2.34.1
• 2.33.0
• 2.32.1
• 2.31.1
• 2.30.1
• 2.24.0
• 2.23.3
• 2.22.0
• 2.21.0
• 2.20.1
• 2.19.6
• 2.18.7
• 2.17.0
• 2.16.0
• 2.15.0
• 2.14.0
• 2.13.0
• 2.12.2
• 2.11.0
• 2.10.0
• 2.9.0
• 2.8.1
• 2.7.1

public interface RetryingExecutor<ResponseT>

A retrying executor is responsible for the following operations:

1. Creating first attempt RetryingFuture, which acts as a facade, hiding from client code the actual execution of scheduled retry attempts.
2. Executing the actual Callable in a retriable context.

This interface is for internal/advanced use only.

Type Parameter

Name	Description
ResponseT

Methods

createFuture(Callable<ResponseT> callable)

public abstract RetryingFuture<ResponseT> createFuture(Callable<ResponseT> callable)

Creates the RetryingFuture, which is a facade, returned to the client code to wait for any retriable operation to complete.

Parameter

Name	Description
callable	Callable<ResponseT> the actual callable, which should be executed in a retriable context

Returns

Type	Description
RetryingFuture<ResponseT>	retrying future facade

submit(RetryingFuture<ResponseT> retryingFuture)

public abstract ApiFuture<ResponseT> submit(RetryingFuture<ResponseT> retryingFuture)

Submits an attempt for execution. A typical implementation will either try to execute the attempt in the current thread or schedule it for an execution, using some sort of async execution service.

Parameter

Name	Description
retryingFuture	RetryingFuture<ResponseT> the future previously returned by #createFuture(Callable) and reused for each subsequent attempt of same operation.

Returns

Type	Description
ApiFuture<ResponseT>	submitted attempt future