public static class LocalStatsMatsInterceptor.EndpointStatsImpl extends java.lang.Object implements LocalStatsMatsInterceptor.EndpointStats
Modifier and Type | Method and Description |
---|---|
java.util.NavigableMap<LocalStatsMatsInterceptor.IncomingMessageRepresentation,io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot> |
getInitiatorToTerminatorTimeNanos()
Only relevant for Endpoints that
LocalStatsMatsInterceptor.EndpointStats.isTerminatorEndpoint() . Terminator endpoints have a special
set of timings: Time taken from the start of initiation to the terminator receives it. |
java.util.Map<MatsStage<?,?,?>,io.mats3.localinspect.LocalStatsMatsInterceptor.StageStatsImpl> |
getStagesMap() |
java.util.List<LocalStatsMatsInterceptor.StageStats> |
getStagesStats() |
LocalStatsMatsInterceptor.StageStats |
getStageStats(MatsStage<?,?,?> stage) |
io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot |
getTotalEndpointProcessingTimeNanos() |
boolean |
isTerminatorEndpoint() |
public java.util.Map<MatsStage<?,?,?>,io.mats3.localinspect.LocalStatsMatsInterceptor.StageStatsImpl> getStagesMap()
public boolean isTerminatorEndpoint()
isTerminatorEndpoint
in interface LocalStatsMatsInterceptor.EndpointStats
void
, in which case it is regarded as a Terminator endpoint.public java.util.List<LocalStatsMatsInterceptor.StageStats> getStagesStats()
getStagesStats
in interface LocalStatsMatsInterceptor.EndpointStats
public LocalStatsMatsInterceptor.StageStats getStageStats(MatsStage<?,?,?> stage)
getStageStats
in interface LocalStatsMatsInterceptor.EndpointStats
public io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot getTotalEndpointProcessingTimeNanos()
getTotalEndpointProcessingTimeNanos
in interface LocalStatsMatsInterceptor.EndpointStats
public java.util.NavigableMap<LocalStatsMatsInterceptor.IncomingMessageRepresentation,io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot> getInitiatorToTerminatorTimeNanos()
LocalStatsMatsInterceptor.EndpointStats
LocalStatsMatsInterceptor.EndpointStats.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.getInitiatorToTerminatorTimeNanos
in interface LocalStatsMatsInterceptor.EndpointStats