com.arakelian.elastic.bulk.event

Class IndexerEventPublisher

java.lang.Object

com.arakelian.elastic.bulk.event.IndexerEventPublisher

All Implemented Interfaces:

IndexerListener, java.io.Closeable, java.lang.AutoCloseable

public class IndexerEventPublisher
extends java.lang.Object
implements IndexerListener, java.io.Closeable

Constructor Summary

Constructors

Constructor and Description
IndexerEventPublisher(int ringBufferSize, com.lmax.disruptor.EventHandler<IndexerEvent>... handlers)
IndexerEventPublisher(com.lmax.disruptor.RingBuffer<IndexerEvent> ringBuffer)

Method Summary

Modifier and Type	Method and Description
void	close()
void	closed(BulkIndexerStats stats) Finished
void	onFailure(BulkOperation op, BulkResponse.BulkOperationResponse response) Invoked when a BulkOperation fails individually.
void	onFailure(BulkOperation op, BulkResponse result) Invoked when a BulkOperation fails because the entire request to the Elastic Bulk API failed, always returning an HTTP status code outside the 2xx range.
void	onFailure(BulkOperation op, java.lang.Throwable t) Invoked when a BulkOperation fails because the entire request failed, usually due to an IOException.
void	onSuccess(BulkOperation op) Invoked when a BulkOperation is successful.

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexerEventPublisher

@SafeVarargs
public IndexerEventPublisher(int ringBufferSize,
                                          com.lmax.disruptor.EventHandler<IndexerEvent>... handlers)

IndexerEventPublisher

public IndexerEventPublisher(com.lmax.disruptor.RingBuffer<IndexerEvent> ringBuffer)

Method Detail

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

closed

public void closed(BulkIndexerStats stats)

Description copied from interface: IndexerListener

Finished

Specified by:

closed in interface IndexerListener

Parameters:

stats - indexer stats

onFailure

public void onFailure(BulkOperation op,
                      BulkResponse.BulkOperationResponse response)

Description copied from interface: IndexerListener

Invoked when a BulkOperation fails individually. These operations always have a status code outside the 2xx range, and they are generally not retryable because they have status codes below the 5xx range, which are reserved for server-side issues.

Specified by:

onFailure in interface IndexerListener

Parameters:

op - bulk operation

response - bulk operation response

onFailure

public void onFailure(BulkOperation op,
                      BulkResponse result)

Description copied from interface: IndexerListener

Invoked when a BulkOperation fails because the entire request to the Elastic Bulk API failed, always returning an HTTP status code outside the 2xx range. Note: The bulk API request would been retried according to configured BulkIndexerConfig.getRetryer() policy.

Specified by:

onFailure in interface IndexerListener

Parameters:

op - bulk operation that failed

result - the response from the Elastic Bulk API, always with status code outside the 2xx range.

onFailure

public void onFailure(BulkOperation op,
                      java.lang.Throwable t)

Description copied from interface: IndexerListener

Invoked when a BulkOperation fails because the entire request failed, usually due to an IOException. It's possible that the Elastic Bulk API never received the request. Note: The bulk API request would been retried according to configured BulkIndexerConfig.getRetryer() policy.

Specified by:

onFailure in interface IndexerListener

Parameters:

op - bulk operation that failed

t - the exception that caused failure, usually an IOException

onSuccess

public void onSuccess(BulkOperation op)

Description copied from interface: IndexerListener

Invoked when a BulkOperation is successful. These operations usually have a status code in the 2xx range, but there are exceptions, such as 404 status code for delete operations which are benign and merely reported that the requested record was not found.

Specified by:

onSuccess in interface IndexerListener

Parameters:

op - bulk operation