Package org.graylog2.outputs.filter

Class PipelineRuleOutputFilterStateUpdater

java.lang.Object

org.graylog2.outputs.filter.PipelineRuleOutputFilterStateUpdater

@Singleton
public class PipelineRuleOutputFilterStateUpdater
extends Object

State updater for the PipelineRuleOutputFilter.

Constructor Summary

Constructors

Constructor	Description
PipelineRuleOutputFilterStateUpdater(StreamDestinationFilterService filterService, PipelineRuleOutputFilterState.Factory stateFactory, Map<String,FilteredMessageOutput> filteredOutputs, RuleBuilderService ruleBuilderService, PipelineResolver.Factory resolverFactory, PipelineRuleParser pipelineRuleParser, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method	Description
void	init(AtomicReference<PipelineRuleOutputFilterState> activeState)
void	reloadForDelete(AtomicReference<PipelineRuleOutputFilterState> activeState, Set<String> deletedFilterRuleIds)
void	reloadForUpdate(AtomicReference<PipelineRuleOutputFilterState> activeState, Set<String> updatedFilterRuleIds)

Methods inherited from class java.lang.Object

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

Constructor Details

PipelineRuleOutputFilterStateUpdater

@Inject
public PipelineRuleOutputFilterStateUpdater(StreamDestinationFilterService filterService,
 PipelineRuleOutputFilterState.Factory stateFactory,
 Map<String,FilteredMessageOutput> filteredOutputs,
 RuleBuilderService ruleBuilderService,
 PipelineResolver.Factory resolverFactory,
 PipelineRuleParser pipelineRuleParser,
 com.codahale.metrics.MetricRegistry metricRegistry)

Method Details

init

public void init(AtomicReference<PipelineRuleOutputFilterState> activeState)

reloadForUpdate

public void reloadForUpdate(AtomicReference<PipelineRuleOutputFilterState> activeState,
 Set<String> updatedFilterRuleIds)

reloadForDelete

public void reloadForDelete(AtomicReference<PipelineRuleOutputFilterState> activeState,
 Set<String> deletedFilterRuleIds)