Package io.grpc.xds.client

Class LoadStatsManager2.ClusterLocalityStats

  • Enclosing class:
    LoadStatsManager2
    @ThreadSafe
public final class LoadStatsManager2.ClusterLocalityStats
extends java.lang.Object
    Recorder for client loads. One instance per locality (in cluster with edsService).

    • Field Detail

      • clusterName

        private final java.lang.String clusterName

      • edsServiceName

        @Nullable
private final java.lang.String edsServiceName

      • locality

        private final Locality locality

      • stopwatch

        private final com.google.common.base.Stopwatch stopwatch

      • callsInProgress

        private final java.util.concurrent.atomic.AtomicLong callsInProgress

      • callsSucceeded

        private final java.util.concurrent.atomic.AtomicLong callsSucceeded

      • callsFailed

        private final java.util.concurrent.atomic.AtomicLong callsFailed

      • callsIssued

        private final java.util.concurrent.atomic.AtomicLong callsIssued

    • Constructor Detail

      • ClusterLocalityStats

        private ClusterLocalityStats​(java.lang.String clusterName,
                             @Nullable
                             java.lang.String edsServiceName,
                             Locality locality,
                             com.google.common.base.Stopwatch stopwatch)

    • Method Detail

      • recordCallStarted

        public void recordCallStarted()
        Records a request being issued.

      • recordCallFinished

        public void recordCallFinished​(io.grpc.Status status)
        Records a request finished with the given status.

      • recordBackendLoadMetricStats

        public void recordBackendLoadMetricStats​(java.util.Map<java.lang.String,​java.lang.Double> namedMetrics)
        Records all custom named backend load metric stats for per-call load reporting. For each metric key name, creates a new Stats.BackendLoadMetricStats with a finished requests counter of 1 and the value if the key is not present in the map. Otherwise, increments the finished requests counter and adds the value to the existing Stats.BackendLoadMetricStats.