Package org.graylog2.system.traffic

Class TrafficCounterService

java.lang.Object

org.graylog2.system.traffic.TrafficCounterService

All Implemented Interfaces:

TrafficUpdater

public class TrafficCounterService
extends Object
implements TrafficUpdater

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	TrafficCounterService.Interval
static class	TrafficCounterService.TrafficHistogram
static class	TrafficCounterService.TrafficHistograms

Constructor Summary

Constructors

Constructor	Description
TrafficCounterService(MongoCollections mongoCollections)

Method Summary

Modifier and Type	Method	Description
TrafficCounterService.TrafficHistogram	clusterTrafficOfLastDays(org.joda.time.Duration daysToIncludeDuration, TrafficCounterService.Interval interval)	Method included for backwards compatibility in pre-5.0 Graylog versions.
TrafficCounterService.TrafficHistogram	clusterTrafficOfLastDays(org.joda.time.Duration daysToIncludeDuration, TrafficCounterService.Interval interval, boolean includeToday)	Queries traffic for the specified duration.
static org.bson.conversions.Bson	createQuery(org.joda.time.DateTime to, org.joda.time.DateTime from)
static TrafficCounterService.TrafficHistograms	createTrafficHistograms(org.joda.time.Duration daysToIncludeDuration, boolean includeToday)
static org.bson.conversions.Bson	incUpdate(String fieldInput, String escapedNodeId, long inLastMinute)
static long	sumTraffic(Map<String,Long> sumTraffic)
void	updateTraffic(org.joda.time.DateTime observationTime, NodeId nodeId, long inLastMinute, long outLastMinute, long decodedLastMinute)

Methods inherited from class java.lang.Object

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

Constructor Details

TrafficCounterService

@Inject
public TrafficCounterService(MongoCollections mongoCollections)

Method Details

updateTraffic

public void updateTraffic(org.joda.time.DateTime observationTime,
 NodeId nodeId,
 long inLastMinute,
 long outLastMinute,
 long decodedLastMinute)

Specified by:

updateTraffic in interface TrafficUpdater

incUpdate

public static org.bson.conversions.Bson incUpdate(String fieldInput,
 String escapedNodeId,
 long inLastMinute)

clusterTrafficOfLastDays

public TrafficCounterService.TrafficHistogram clusterTrafficOfLastDays(org.joda.time.Duration daysToIncludeDuration,
 TrafficCounterService.Interval interval)

Method included for backwards compatibility in pre-5.0 Graylog versions.

clusterTrafficOfLastDays

public TrafficCounterService.TrafficHistogram clusterTrafficOfLastDays(org.joda.time.Duration daysToIncludeDuration,
 TrafficCounterService.Interval interval,
 boolean includeToday)

Queries traffic for the specified duration.
The from-date is considered to be the start of the day that the duration intersects with in the past. For example, if a duration of 1.5 days is specified, then traffic starting from the beginning of two days ago will be returned.
The to-date is considered to be the current date/time (now) when includeToday false, otherwise then the end of the previous day will be used.

createTrafficHistograms

public static TrafficCounterService.TrafficHistograms createTrafficHistograms(org.joda.time.Duration daysToIncludeDuration,
 boolean includeToday)

createQuery

public static org.bson.conversions.Bson createQuery(org.joda.time.DateTime to,
 org.joda.time.DateTime from)

sumTraffic

public static long sumTraffic(Map<String,Long> sumTraffic)