io.mats3.localinspect

Interface LocalStatsMatsInterceptor.StageStats

Enclosing class:

LocalStatsMatsInterceptor

public static interface LocalStatsMatsInterceptor.StageStats

Method Summary

Modifier and Type	Method and Description
java.util.Optional<io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot>	getBetweenStagesTimeNanos() Note: Not present for the isInitial() stage, as there is no "between" for the initial stage.
java.util.NavigableMap<LocalStatsMatsInterceptor.IncomingMessageRepresentation,java.lang.Long>	getIncomingMessageCounts()
int	getIndex()
java.util.NavigableMap<LocalStatsMatsInterceptor.OutgoingMessageRepresentation,java.lang.Long>	getOutgoingMessageCounts()
java.util.NavigableMap<MatsStageInterceptor.StageCompletedContext.ProcessResult,java.lang.Long>	getProcessResultCounts()
io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot	getSpentQueueTimeNanos() Note: Only has millisecond resolution, AND is susceptible to time skews between nodes (uses System.currentTimeMillis() on the sending and receiving node).
io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot	getStageTotalExecutionTimeNanos()
boolean	isInitial()

Method Detail

getIndex

int getIndex()

isInitial

boolean isInitial()

getSpentQueueTimeNanos

io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot getSpentQueueTimeNanos()

Note: Only has millisecond resolution, AND is susceptible to time skews between nodes (uses System.currentTimeMillis() on the sending and receiving node).

getBetweenStagesTimeNanos

java.util.Optional<io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot> getBetweenStagesTimeNanos()

Note: Not present for the isInitial() stage, as there is no "between" for the initial stage.

Note: Only recorded for messages that happens to have the two "between" stages executed on the same node, to both eliminate time skews between nodes, and to get higher precision (nanoTime()).

getStageTotalExecutionTimeNanos

io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot getStageTotalExecutionTimeNanos()

Returns:

the stage's total execution time (from right after received, to right before going back to receive loop).

getIncomingMessageCounts

java.util.NavigableMap<LocalStatsMatsInterceptor.IncomingMessageRepresentation,java.lang.Long> getIncomingMessageCounts()

getProcessResultCounts

java.util.NavigableMap<MatsStageInterceptor.StageCompletedContext.ProcessResult,java.lang.Long> getProcessResultCounts()

getOutgoingMessageCounts

java.util.NavigableMap<LocalStatsMatsInterceptor.OutgoingMessageRepresentation,java.lang.Long> getOutgoingMessageCounts()