Package org.elasticsearch.action.ingest

Class IngestActionForwarder

java.lang.Object

org.elasticsearch.action.ingest.IngestActionForwarder

All Implemented Interfaces:

ClusterStateApplier

public final class IngestActionForwarder
extends java.lang.Object
implements ClusterStateApplier

A utility for forwarding ingest requests to ingest nodes in a round-robin fashion. TODO: move this into IngestService and make index/bulk actions call that

Constructor Summary

Constructors

Constructor	Description
IngestActionForwarder(TransportService transportService)

Method Summary

Modifier and Type	Method	Description
void	applyClusterState(ClusterChangedEvent event)	Called when a new cluster state (ClusterChangedEvent.state() needs to be applied.
void	forwardIngestRequest(ActionType<?> action, ActionRequest request, ActionListener<?> listener)

Methods inherited from class java.lang.Object

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

Constructor Details

IngestActionForwarder

public IngestActionForwarder(TransportService transportService)

Method Details

forwardIngestRequest

public void forwardIngestRequest(ActionType<?> action, ActionRequest request, ActionListener<?> listener)

applyClusterState

public void applyClusterState(ClusterChangedEvent event)

Description copied from interface: ClusterStateApplier

Called when a new cluster state (ClusterChangedEvent.state() needs to be applied. The cluster state to be applied is already committed when this method is called, so an applier must therefore be prepared to deal with any state it receives without throwing an exception. Throwing an exception from an applier is very bad because it will stop the application of this state before it has reached all the other appliers, and will likely result in another attempt to apply the same (or very similar) cluster state which might continue until this node is removed from the cluster.

Specified by:

applyClusterState in interface ClusterStateApplier