LocalStatsMatsInterceptor.StageStats (mats3 0.19.9-2023-05-04 API)

Enclosing class:: LocalStatsMatsInterceptor

public static interface LocalStatsMatsInterceptor.StageStats

Method Summary

Modifier and Type

Method

Description

Optional<io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot>

getBetweenStagesTimeNanos()

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

NavigableMap<LocalStatsMatsInterceptor.IncomingMessageRepresentation,Long>

getIncomingMessageCounts()

int

getIndex()

NavigableMap<LocalStatsMatsInterceptor.OutgoingMessageRepresentation,Long>

getOutgoingMessageCounts()

NavigableMap<MatsStageInterceptor.StageCompletedContext.ProcessResult,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 Details
- 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
  
  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
  
  NavigableMap<LocalStatsMatsInterceptor.IncomingMessageRepresentation,Long> getIncomingMessageCounts()
- getProcessResultCounts
  
  NavigableMap<MatsStageInterceptor.StageCompletedContext.ProcessResult,Long> getProcessResultCounts()
- getOutgoingMessageCounts
  
  NavigableMap<LocalStatsMatsInterceptor.OutgoingMessageRepresentation,Long> getOutgoingMessageCounts()