org.graylog2.streams

Class StreamRouter

java.lang.Object

org.graylog2.streams.StreamRouter

Direct Known Subclasses:

CachedStreamRouter

public class StreamRouter
extends java.lang.Object

Routes a GELF message to its streams.

Field Summary

Fields

Modifier and Type	Field and Description
protected StreamRuleService	streamRuleService
protected StreamService	streamService

Constructor Summary

Constructors

Constructor and Description
StreamRouter(StreamService streamService, StreamRuleService streamRuleService, com.codahale.metrics.MetricRegistry metricRegistry, Configuration configuration, NotificationService notificationService)

Method Summary

Modifier and Type	Method and Description
boolean	doesStreamMatch(java.util.Map<StreamRule,java.lang.Boolean> ruleMatches)
protected com.codahale.metrics.Meter	getExceptionMeter(java.lang.String streamId)
protected com.codahale.metrics.Timer	getExecutionTimer(java.lang.String streamId)
protected com.codahale.metrics.Meter	getIncomingMeter(java.lang.String streamId)
java.util.Map<StreamRule,java.lang.Boolean>	getRuleMatches(Stream stream, Message msg)
protected com.codahale.metrics.Meter	getStreamFaultsExceededMeter(java.lang.String streamId)
protected com.codahale.metrics.Meter	getStreamRuleTimeoutMeter(java.lang.String streamId)
boolean	matchStreamRule(Message msg, StreamRuleMatcher matcher, StreamRule rule)
java.util.List<Stream>	route(Message msg)

Methods inherited from class java.lang.Object

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

Field Detail

streamService

protected final StreamService streamService

streamRuleService

protected final StreamRuleService streamRuleService

Constructor Detail

StreamRouter

@Inject
public StreamRouter(StreamService streamService,
                            StreamRuleService streamRuleService,
                            com.codahale.metrics.MetricRegistry metricRegistry,
                            Configuration configuration,
                            NotificationService notificationService)

Method Detail

route

public java.util.List<Stream> route(Message msg)

getRuleMatches

public java.util.Map<StreamRule,java.lang.Boolean> getRuleMatches(Stream stream,
                                                                  Message msg)

doesStreamMatch

public boolean doesStreamMatch(java.util.Map<StreamRule,java.lang.Boolean> ruleMatches)

matchStreamRule

public boolean matchStreamRule(Message msg,
                               StreamRuleMatcher matcher,
                               StreamRule rule)

getIncomingMeter

protected com.codahale.metrics.Meter getIncomingMeter(java.lang.String streamId)

getExecutionTimer

protected com.codahale.metrics.Timer getExecutionTimer(java.lang.String streamId)

getExceptionMeter

protected com.codahale.metrics.Meter getExceptionMeter(java.lang.String streamId)

getStreamRuleTimeoutMeter

protected com.codahale.metrics.Meter getStreamRuleTimeoutMeter(java.lang.String streamId)

getStreamFaultsExceededMeter

protected com.codahale.metrics.Meter getStreamFaultsExceededMeter(java.lang.String streamId)