org.graylog2.streams

Class StreamRouter

java.lang.Object

org.graylog2.streams.StreamRouter

Direct Known Subclasses:

CachedStreamRouter

public class StreamRouter
extends Object

Routes a GELF Message to it's streams.

Author:

Lennart Koopmann

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	LOG
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

Methods

Modifier and Type	Method and Description
boolean	doesStreamMatch(Map<StreamRule,Boolean> ruleMatches)
protected com.codahale.metrics.Meter	getExceptionMeter(String streamId)
protected com.codahale.metrics.Timer	getExecutionTimer(String streamId)
protected com.codahale.metrics.Meter	getIncomingMeter(String streamId)
Map<StreamRule,Boolean>	getRuleMatches(Stream stream, Message msg)
boolean	matchStreamRule(Message msg, StreamRuleMatcher matcher, StreamRule rule)
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

LOG

protected final org.slf4j.Logger LOG

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 List<Stream> route(Message msg)

getRuleMatches

public Map<StreamRule,Boolean> getRuleMatches(Stream stream,
                                     Message msg)

doesStreamMatch

public boolean doesStreamMatch(Map<StreamRule,Boolean> ruleMatches)

matchStreamRule

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

getIncomingMeter

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

getExecutionTimer

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

getExceptionMeter

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