Package org.graylog2.outputs.filter

Class PipelineRuleOutputFilter

java.lang.Object

org.graylog2.outputs.filter.PipelineRuleOutputFilter

All Implemented Interfaces:

OutputFilter

@Singleton
public class PipelineRuleOutputFilter
extends Object
implements OutputFilter

An OutputFilter that filters messages with pipeline processor rules based on stream destination filters.

See Also:

• StreamDestinationFilterService

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	PipelineRuleOutputFilter.Metadata

Field Summary

Fields

Modifier and Type	Field	Description
static final String	METADATA_KEY

Constructor Summary

Constructors

Constructor	Description
PipelineRuleOutputFilter(PipelineRuleOutputFilterStateUpdater stateUpdater, ScheduledExecutorService scheduler, com.codahale.metrics.MetricRegistry metricRegistry, com.google.common.eventbus.EventBus eventBus)

Method Summary

Modifier and Type	Method	Description
FilteredMessage	apply(Message msg)

Methods inherited from class java.lang.Object

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

Field Details

METADATA_KEY

public static final String METADATA_KEY

Constructor Details

PipelineRuleOutputFilter

@Inject
public PipelineRuleOutputFilter(PipelineRuleOutputFilterStateUpdater stateUpdater,
 @Named("daemonScheduler")
 ScheduledExecutorService scheduler,
 com.codahale.metrics.MetricRegistry metricRegistry,
 com.google.common.eventbus.EventBus eventBus)

Method Details

apply

public FilteredMessage apply(Message msg)

Specified by:

apply in interface OutputFilter