public static interface LocalStatsMatsInterceptor.EndpointStats
Modifier and Type | Method and Description |
---|---|
java.util.NavigableMap<LocalStatsMatsInterceptor.IncomingMessageRepresentation,io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot> |
getInitiatorToTerminatorTimeNanos()
Only relevant for Endpoints that
isTerminatorEndpoint() . Terminator endpoints have a special
set of timings: Time taken from the start of initiation to the terminator receives it. |
java.util.List<LocalStatsMatsInterceptor.StageStats> |
getStagesStats() |
LocalStatsMatsInterceptor.StageStats |
getStageStats(MatsStage<?,?,?> stage) |
io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot |
getTotalEndpointProcessingTimeNanos() |
boolean |
isTerminatorEndpoint() |
java.util.List<LocalStatsMatsInterceptor.StageStats> getStagesStats()
LocalStatsMatsInterceptor.StageStats getStageStats(MatsStage<?,?,?> stage)
io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot getTotalEndpointProcessingTimeNanos()
boolean isTerminatorEndpoint()
void
, in which case it is regarded as a Terminator endpoint.java.util.NavigableMap<LocalStatsMatsInterceptor.IncomingMessageRepresentation,io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot> getInitiatorToTerminatorTimeNanos()
isTerminatorEndpoint()
. Terminator endpoints have a special
set of timings: Time taken from the start of initiation to the terminator receives it. Note: Most initiations
specify a terminator in the same codebase as the initiation, but this is not a requirement. This timing is
special in that it uses the differences in initiation timestamp (System.currentTimeMillis()) vs. reception at
terminator (with millisecond precision) until it sees a reception that is on the same nodename as the
initiation. At that point it switches over to using only timings that go between initiation and reception on
the same node - this both removes the problem of time skews, and provide for more precise timings (since it
uses System.nanoTime()), at the expense of only sampling a subset of the available observations.