Class StrideTracker<D>
java.lang.Object
io.nosqlbench.engine.api.activityapi.cyclelog.buffers.Buffer<CompletedOp<D>>
io.nosqlbench.engine.api.activityimpl.motor.StrideTracker<D>
- All Implemented Interfaces:
OpEvents<D>,CycleResultsSegment,Comparable<CycleResultsSegment>,Iterable<CycleResult>
public class StrideTracker<D>
extends Buffer<CompletedOp<D>>
implements OpEvents<D>, CycleResultsSegment
-
Nested Class Summary
Nested classes/interfaces inherited from interface io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResultsSegment
CycleResultsSegment.EmptySegment -
Field Summary
Fields inherited from interface io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResultsSegment
EMPTY -
Constructor Summary
ConstructorsConstructorDescriptionStrideTracker(com.codahale.metrics.Timer strideServiceTimer, com.codahale.metrics.Timer strideResponseTimer, long strideWaitTime, long initialCycle, int size, Output output, StrideOutputConsumer<D> outputReader) -
Method Summary
Modifier and TypeMethodDescriptionprotected intcompare(CompletedOp<D> one, CompletedOp<D> other) longgetCount()longiterator()voidonFull()When a stride is complete, do house keeping.voidonOpFailure(FailedOp<D> op) voidonOpSkipped(SkippedOp<D> op) voidonOpStarted(StartedOp<D> op) voidonOpSuccess(SucceededOp<D> op) voidstart()Each strideOp opTracker must be started before any ops that it tracksMethods inherited from class io.nosqlbench.engine.api.activityapi.cyclelog.buffers.Buffer
getFlippedData, put, remaining, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResultsSegment
compareTo, filterMethods inherited from interface java.lang.Iterable
forEach, spliterator
-
Constructor Details
-
StrideTracker
public StrideTracker(com.codahale.metrics.Timer strideServiceTimer, com.codahale.metrics.Timer strideResponseTimer, long strideWaitTime, long initialCycle, int size, Output output, StrideOutputConsumer<D> outputReader)
-
-
Method Details
-
start
public void start()Each strideOp opTracker must be started before any ops that it tracks -
onOpStarted
- Specified by:
onOpStartedin interfaceOpEvents<D>
-
onOpSuccess
- Specified by:
onOpSuccessin interfaceOpEvents<D>
-
onOpFailure
- Specified by:
onOpFailurein interfaceOpEvents<D>
-
onOpSkipped
- Specified by:
onOpSkippedin interfaceOpEvents<D>
-
onFull
public void onFull()When a stride is complete, do house keeping. This effectively means when N==stride ops have been submitted to this buffer, which is tracked byBuffer.put(Comparable).- Overrides:
onFullin classBuffer<CompletedOp<D>>
-
compare
- Specified by:
comparein classBuffer<CompletedOp<D>>
-
getCount
public long getCount()- Specified by:
getCountin interfaceCycleResultsSegment
-
getMinCycle
public long getMinCycle()- Specified by:
getMinCyclein interfaceCycleResultsSegment
-
iterator
-