org.datadog.statitics

Class TrafficStatisticsManager

java.lang.Object

org.datadog.statitics.TrafficStatisticsManager

public class TrafficStatisticsManager
extends Object

Consumes the events of type CommonLogFormatEntry and generates TrafficStatistic. The events are processed periodically according to the refresh period configuration. The events are stored internally in ConcurrentLinkedQueue and retrieved from an EventBus

Constructor Summary

Constructors

Constructor and Description
TrafficStatisticsManager(com.google.common.eventbus.EventBus eventBus, int refreshPeriod) Creates a consumer of events of type CommonLogFormatEntry.

Method Summary

Modifier and Type	Method and Description
void	consumeClfEvent(CommonLogFormatEntry commonLogFormatEntry) Consumes a CommonLogFormatEntry event.
void	refreshStatistics(Instant maxAge) Processes all the CommonLogFormatEntry present in the buffer whose log date time is "timeSecondsInterval" seconds before now and produces a new TrafficStatistic.

Methods inherited from class java.lang.Object

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

Constructor Detail

TrafficStatisticsManager

@Inject
public TrafficStatisticsManager(com.google.common.eventbus.EventBus eventBus,
                                         int refreshPeriod)

Creates a consumer of events of type CommonLogFormatEntry.

Parameters:

eventBus - The EventBus used to listen to the events of type CommonLogFormatEntry

refreshPeriod - The refresh period in seconds after which the CommonLogFormatEntry events buffer is checked and all the events of the last refresh periods seconds are processed.

Method Detail

refreshStatistics

public void refreshStatistics(Instant maxAge)

Processes all the CommonLogFormatEntry present in the buffer whose log date time is "timeSecondsInterval" seconds before now and produces a new TrafficStatistic.

Parameters:

maxAge - the maximum log date time to process from the buffer.

consumeClfEvent

public void consumeClfEvent(CommonLogFormatEntry commonLogFormatEntry)

Consumes a CommonLogFormatEntry event. It adds the CommonLogFormatEntry to the log buffer if its log date time is after the most recent stored log entry and discards it otherwise.

Parameters:

commonLogFormatEntry - a CommonLogFormatEntry type event.