Package io.mats3.localinspect

Class LocalStatsMatsInterceptor.EndpointStatsImpl

java.lang.Object

io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStatsImpl

All Implemented Interfaces:

LocalStatsMatsInterceptor.EndpointStats

Enclosing class:

LocalStatsMatsInterceptor

public static class LocalStatsMatsInterceptor.EndpointStatsImpl
extends Object
implements LocalStatsMatsInterceptor.EndpointStats

Method Summary

Modifier and Type	Method	Description
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.
Map<MatsStage<?,?,?>,io.mats3.localinspect.LocalStatsMatsInterceptor.StageStatsImpl>	getStagesMap()
List<LocalStatsMatsInterceptor.StageStats>	getStagesStats()
LocalStatsMatsInterceptor.StageStats	getStageStats(MatsStage<?,?,?> stage)
io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot	getTotalEndpointProcessingTimeNanos()
boolean	isTerminatorEndpoint()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getStagesMap

public Map<MatsStage<?,?,?>,io.mats3.localinspect.LocalStatsMatsInterceptor.StageStatsImpl> getStagesMap()

isTerminatorEndpoint

public boolean isTerminatorEndpoint()

Specified by:

isTerminatorEndpoint in interface LocalStatsMatsInterceptor.EndpointStats

Returns:

whether the reply DTO is void, in which case it is regarded as a Terminator endpoint.

getStagesStats

public List<LocalStatsMatsInterceptor.StageStats> getStagesStats()

Specified by:

getStagesStats in interface LocalStatsMatsInterceptor.EndpointStats

getStageStats

public LocalStatsMatsInterceptor.StageStats getStageStats(MatsStage<?,?,?> stage)

Specified by:

getStageStats in interface LocalStatsMatsInterceptor.EndpointStats

getTotalEndpointProcessingTimeNanos

public io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot getTotalEndpointProcessingTimeNanos()

Specified by:

getTotalEndpointProcessingTimeNanos in interface LocalStatsMatsInterceptor.EndpointStats

getInitiatorToTerminatorTimeNanos

public NavigableMap<LocalStatsMatsInterceptor.IncomingMessageRepresentation,io.mats3.localinspect.LocalStatsMatsInterceptor.StatsSnapshot> getInitiatorToTerminatorTimeNanos()

Description copied from interface: LocalStatsMatsInterceptor.EndpointStats

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. 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.

Specified by:

getInitiatorToTerminatorTimeNanos in interface LocalStatsMatsInterceptor.EndpointStats