com.tomtom.speedtools.tracer.mongo

Class MongoDBTraceStream

java.lang.Object

com.tomtom.speedtools.tracer.TraceHandlerCollection

com.tomtom.speedtools.tracer.mongo.MongoDBTraceStream

All Implemented Interfaces:

TraceStream

public class MongoDBTraceStream
extends TraceHandlerCollection
implements TraceStream

Class that reads trace events from a MongoDB database.

Constructor Summary

Constructors

Constructor and Description
MongoDBTraceStream(MongoDBTraceProperties properties)

Method Summary

Modifier and Type	Method and Description
com.tomtom.speedtools.tracer.mongo.MongoDBTraceFetcher	getFetcher() Return the trace fetcher, in case you wish to walk through events in your own code.
org.joda.time.DateTime	moveTo(org.joda.time.DateTime time) Rewinds the stream to given moment in time.
org.joda.time.DateTime	moveToEnd() Fast-forwards to the end of the stream.
org.joda.time.DateTime	moveToStart() Fast-rewinds to the start of the stream.
void	playbackTo(org.joda.time.DateTime until) Process remaining events up until given time.
void	playbackToEnd() Process all remaining events.

Methods inherited from class com.tomtom.speedtools.tracer.TraceHandlerCollection

addTraceHandler, handleTrace, handleTraces, removeAllTraceHandlers, removeTraceHandler

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.tomtom.speedtools.tracer.TraceStream

addTraceHandler, removeTraceHandler

Constructor Detail

MongoDBTraceStream

@Inject
public MongoDBTraceStream(@Nonnull
                                  MongoDBTraceProperties properties)
                           throws UnknownHostException

Throws:

UnknownHostException

Method Detail

moveTo

@Nullable
public org.joda.time.DateTime moveTo(@Nonnull
                                               org.joda.time.DateTime time)

Description copied from interface: TraceStream

Rewinds the stream to given moment in time. From now on, processing occurs for events from this time. Given time is inclusive.

Specified by:

moveTo in interface TraceStream

Parameters:

time - Time to move to.

Returns:

Actual time moved to.

moveToStart

@Nullable
public org.joda.time.DateTime moveToStart()

Description copied from interface: TraceStream

Fast-rewinds to the start of the stream. All events currently in the stream will be skipped when any of the process methods is called.

Specified by:

moveToStart in interface TraceStream

Returns:

Actual time moved to.

moveToEnd

@Nullable
public org.joda.time.DateTime moveToEnd()

Description copied from interface: TraceStream

Fast-forwards to the end of the stream. All events currently in the stream will be skipped when any of the process methods is called.

Specified by:

moveToEnd in interface TraceStream

Returns:

Actual time moved to.

playbackTo

public void playbackTo(@Nonnull
                       org.joda.time.DateTime until)

Description copied from interface: TraceStream

Process remaining events up until given time. Any previously processed events will not be processed again, except after a call to setPosition.

Specified by:

playbackTo in interface TraceStream

Parameters:

until - Time until when to process events, exclusive.

playbackToEnd

public void playbackToEnd()

Description copied from interface: TraceStream

Process all remaining events. Any previously processed events will not be processed again, except after a call to setPosition.

Specified by:

playbackToEnd in interface TraceStream

getFetcher

@Nonnull
public com.tomtom.speedtools.tracer.mongo.MongoDBTraceFetcher getFetcher()

Return the trace fetcher, in case you wish to walk through events in your own code.

Returns:

The trace fetcher.