Package org.elasticsearch.ingest

Class PipelineStore

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.ingest.PipelineStore

All Implemented Interfaces:

ClusterStateApplier

public class PipelineStore
extends AbstractComponent
implements ClusterStateApplier

Field Summary

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor	Description
PipelineStore(Settings settings, java.util.Map<java.lang.String,Processor.Factory> processorFactories)

Method Summary

Modifier and Type	Method	Description
void	applyClusterState(ClusterChangedEvent event)	Called when a new cluster state (ClusterChangedEvent.state() needs to be applied
void	delete(ClusterService clusterService, DeletePipelineRequest request, ActionListener<WritePipelineResponse> listener)	Deletes the pipeline specified by id in the request.
Pipeline	get(java.lang.String id)	Returns the pipeline by the specified id
java.util.List<PipelineConfiguration>	getPipelines(ClusterState clusterState, java.lang.String... ids)
java.util.Map<java.lang.String,Processor.Factory>	getProcessorFactories()
void	put(ClusterService clusterService, java.util.Map<DiscoveryNode,IngestInfo> ingestInfos, PutPipelineRequest request, ActionListener<WritePipelineResponse> listener)	Stores the specified pipeline definition in the request.

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class java.lang.Object

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

Constructor Detail

PipelineStore

public PipelineStore(Settings settings,
                     java.util.Map<java.lang.String,Processor.Factory> processorFactories)

Method Detail

applyClusterState

public void applyClusterState(ClusterChangedEvent event)

Description copied from interface: ClusterStateApplier

Called when a new cluster state (ClusterChangedEvent.state() needs to be applied

Specified by:

applyClusterState in interface ClusterStateApplier

delete

public void delete(ClusterService clusterService,
                   DeletePipelineRequest request,
                   ActionListener<WritePipelineResponse> listener)

Deletes the pipeline specified by id in the request.

put

public void put(ClusterService clusterService,
                java.util.Map<DiscoveryNode,IngestInfo> ingestInfos,
                PutPipelineRequest request,
                ActionListener<WritePipelineResponse> listener)
         throws java.lang.Exception

Stores the specified pipeline definition in the request.

Throws:

java.lang.Exception

get

public Pipeline get(java.lang.String id)

Returns the pipeline by the specified id

getProcessorFactories

public java.util.Map<java.lang.String,Processor.Factory> getProcessorFactories()

getPipelines

public java.util.List<PipelineConfiguration> getPipelines(ClusterState clusterState,
                                                          java.lang.String... ids)

Returns:

pipeline configuration specified by id. If multiple ids or wildcards are specified multiple pipelines may be returned