public class PipelineExecutionService extends java.lang.Object implements ClusterStateApplier
Constructor and Description |
---|
PipelineExecutionService(PipelineStore store,
ThreadPool threadPool) |
Modifier and Type | Method and Description |
---|---|
void |
applyClusterState(ClusterChangedEvent event)
Called when a new cluster state (
ClusterChangedEvent.state() needs to be applied |
void |
executeBulkRequest(java.lang.Iterable<DocWriteRequest> actionRequests,
java.util.function.BiConsumer<IndexRequest,java.lang.Exception> itemFailureHandler,
java.util.function.Consumer<java.lang.Exception> completionHandler) |
void |
executeIndexRequest(IndexRequest request,
java.util.function.Consumer<java.lang.Exception> failureHandler,
java.util.function.Consumer<java.lang.Boolean> completionHandler) |
IngestStats |
stats() |
public PipelineExecutionService(PipelineStore store, ThreadPool threadPool)
public void executeIndexRequest(IndexRequest request, java.util.function.Consumer<java.lang.Exception> failureHandler, java.util.function.Consumer<java.lang.Boolean> completionHandler)
public void executeBulkRequest(java.lang.Iterable<DocWriteRequest> actionRequests, java.util.function.BiConsumer<IndexRequest,java.lang.Exception> itemFailureHandler, java.util.function.Consumer<java.lang.Exception> completionHandler)
public IngestStats stats()
public void applyClusterState(ClusterChangedEvent event)
ClusterStateApplier
ClusterChangedEvent.state()
needs to be appliedapplyClusterState
in interface ClusterStateApplier