Package org.graylog.plugins.pipelineprocessor.processors

Class PipelineResolver

java.lang.Object

org.graylog.plugins.pipelineprocessor.processors.PipelineResolver

public class PipelineResolver
extends Object

Resolves pipelines, pipeline rules, and pipeline stream connections from database objects to pipeline AST objects.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	PipelineResolver.Factory

Constructor Summary

Constructors

Constructor	Description
PipelineResolver(PipelineRuleParser ruleParser, PipelineResolverConfig config)

Method Summary

Modifier and Type	Method	Description
PipelineResolverConfig	config()	Returns the pipeline resolver configuration.
com.google.common.collect.ImmutableMap<String,Pipeline>	resolveFunctions(Collection<Pipeline> pipelines, PipelineMetricRegistry pipelineMetricRegistry)	Resolve functions for the given set of Pipeline AST objects.
com.google.common.collect.ImmutableMap<String,Pipeline>	resolvePipelines(PipelineMetricRegistry pipelineMetricRegistry)	Resolves the rule and pipeline DAO objects into AST objects.
com.google.common.collect.ImmutableSetMultimap<String,Pipeline>	resolveStreamConnections(Map<String,Pipeline> currentPipelines)	Resolves the stream connection objects for the given pipelines map.

Methods inherited from class java.lang.Object

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

Constructor Details

PipelineResolver

@Inject
public PipelineResolver(PipelineRuleParser ruleParser,
 PipelineResolverConfig config)

Method Details

config

public PipelineResolverConfig config()

Returns the pipeline resolver configuration.

Returns:

the configuration

resolveFunctions

public com.google.common.collect.ImmutableMap<String,Pipeline> resolveFunctions(Collection<Pipeline> pipelines,
 PipelineMetricRegistry pipelineMetricRegistry)

Resolve functions for the given set of Pipeline AST objects. Should only be used when programmatically generating pipeline AST objects.

Parameters:

pipelines - the pipeline AST objects

pipelineMetricRegistry - the metric registry

Returns:

a map of pipeline ID to pipeline instances

resolvePipelines

public com.google.common.collect.ImmutableMap<String,Pipeline> resolvePipelines(PipelineMetricRegistry pipelineMetricRegistry)

Resolves the rule and pipeline DAO objects into AST objects.

Returns:

a map of pipeline ID to pipeline instances

resolveStreamConnections

public com.google.common.collect.ImmutableSetMultimap<String,Pipeline> resolveStreamConnections(Map<String,Pipeline> currentPipelines)

Resolves the stream connection objects for the given pipelines map.

Parameters:

currentPipelines - the pipelines map

Returns:

a multimap of stream ID to pipeline objects