Package org.elasticsearch.action.bulk

Class Retry

java.lang.Object

org.elasticsearch.action.bulk.Retry

public class Retry
extends java.lang.Object

Encapsulates synchronous and asynchronous retry logic.

Constructor Summary

Constructors

Constructor	Description
Retry(java.lang.Class<? extends java.lang.Throwable> retryOnThrowable, BackoffPolicy backoffPolicy, Scheduler scheduler)

Method Summary

Modifier and Type	Method	Description
void	withBackoff(java.util.function.BiConsumer<BulkRequest,ActionListener<BulkResponse>> consumer, BulkRequest bulkRequest, ActionListener<BulkResponse> listener, Settings settings)	Invokes #accept(BulkRequest, ActionListener).
PlainActionFuture<BulkResponse>	withBackoff(java.util.function.BiConsumer<BulkRequest,ActionListener<BulkResponse>> consumer, BulkRequest bulkRequest, Settings settings)	Invokes #accept(BulkRequest, ActionListener).

Methods inherited from class java.lang.Object

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

Constructor Detail

Retry

public Retry(java.lang.Class<? extends java.lang.Throwable> retryOnThrowable,
             BackoffPolicy backoffPolicy,
             Scheduler scheduler)

Method Detail

withBackoff

public void withBackoff(java.util.function.BiConsumer<BulkRequest,ActionListener<BulkResponse>> consumer,
                        BulkRequest bulkRequest,
                        ActionListener<BulkResponse> listener,
                        Settings settings)

Invokes #accept(BulkRequest, ActionListener). Backs off on the provided exception and delegates results to the provided listener. Retries will be scheduled using the class's thread pool.

Parameters:

consumer - The consumer to which apply the request and listener

bulkRequest - The bulk request that should be executed.

listener - A listener that is invoked when the bulk request finishes or completes with an exception. The listener is not

settings - settings

withBackoff

public PlainActionFuture<BulkResponse> withBackoff(java.util.function.BiConsumer<BulkRequest,ActionListener<BulkResponse>> consumer,
                                                   BulkRequest bulkRequest,
                                                   Settings settings)

Invokes #accept(BulkRequest, ActionListener). Backs off on the provided exception. Retries will be scheduled using the class's thread pool.

Parameters:

consumer - The consumer to which apply the request and listener

bulkRequest - The bulk request that should be executed.

settings - settings

Returns:

a future representing the bulk response returned by the client.