Package org.graylog2.outputs.filter

Class PipelineRuleOutputFilterState

java.lang.Object

org.graylog.plugins.pipelineprocessor.processors.PipelineInterpreter.State

org.graylog2.outputs.filter.PipelineRuleOutputFilterState

public class PipelineRuleOutputFilterState
extends PipelineInterpreter.State

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	PipelineRuleOutputFilterState.Factory

Field Summary

Fields inherited from class org.graylog.plugins.pipelineprocessor.processors.PipelineInterpreter.State

STAGE_CACHE_METRIC_SUFFIX

Constructor Summary

Constructors

Constructor	Description
PipelineRuleOutputFilterState(com.google.common.collect.ImmutableMap<String,Pipeline> pipelines, com.google.common.collect.ImmutableSet<String> destinations, com.google.common.collect.ImmutableSet<String> activeStreams, com.codahale.metrics.MetricRegistry metricRegistry, int processorCount, boolean cachedIterators)

Method Summary

Modifier and Type	Method	Description
com.google.common.collect.ImmutableSet<String>	getActiveStreams()
com.google.common.collect.ImmutableSet<String>	getDestinations()
Set<Pipeline>	getPipelinesForMessage(Message msg)
protected String	getStageCacheMetricName()
boolean	isEmpty()

Methods inherited from class org.graylog.plugins.pipelineprocessor.processors.PipelineInterpreter.State

enableRuleMetrics, getCurrentPipelines, getStageIterator, getStreamPipelineConnections

Methods inherited from class java.lang.Object

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

Constructor Details

PipelineRuleOutputFilterState

@Inject
public PipelineRuleOutputFilterState(com.google.common.collect.ImmutableMap<String,Pipeline> pipelines,
 com.google.common.collect.ImmutableSet<String> destinations,
 com.google.common.collect.ImmutableSet<String> activeStreams,
 com.codahale.metrics.MetricRegistry metricRegistry,
 @Named("processbuffer_processors")
 int processorCount,
 @Named("cached_stageiterators")
 boolean cachedIterators)

Method Details

isEmpty

public boolean isEmpty()

getDestinations

public com.google.common.collect.ImmutableSet<String> getDestinations()

getActiveStreams

public com.google.common.collect.ImmutableSet<String> getActiveStreams()

getPipelinesForMessage

public Set<Pipeline> getPipelinesForMessage(Message msg)

getStageCacheMetricName

protected String getStageCacheMetricName()

Overrides:

getStageCacheMetricName in class PipelineInterpreter.State