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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
applyClusterState(ClusterChangedEvent event)
Called when a new cluster state (ClusterChangedEvent.state()
needs to be appliedvoid
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 idjava.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
-
-
-
-
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 interfaceClusterStateApplier
-
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
-
-