Package io.grpc.xds.client

Class LoadStatsManager2.ClusterDropStats

java.lang.Object

io.grpc.xds.client.LoadStatsManager2.ClusterDropStats

Enclosing class:

LoadStatsManager2

@ThreadSafe
public final class LoadStatsManager2.ClusterDropStats
extends java.lang.Object

Recorder for dropped requests. One instance per cluster with edsServiceName.

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.concurrent.ConcurrentMap<java.lang.String,java.util.concurrent.atomic.AtomicLong>	categorizedDrops
private java.lang.String	clusterName
private java.lang.String	edsServiceName
private com.google.common.base.Stopwatch	stopwatch
private java.util.concurrent.atomic.AtomicLong	uncategorizedDrops

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ClusterDropStats(java.lang.String clusterName, java.lang.String edsServiceName, com.google.common.base.Stopwatch stopwatch)

Method Summary

Modifier and Type	Method	Description
void	recordDroppedRequest()	Records a dropped request without category.
void	recordDroppedRequest(java.lang.String category)	Records a dropped request with the specified category.
void	release()	Release the hard reference for this stats object (previously obtained via LoadStatsManager2.getClusterDropStats(java.lang.String, java.lang.String)).
private LoadStatsManager2.ClusterDropStatsSnapshot	snapshot()

Methods inherited from class java.lang.Object

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

Field Detail

clusterName

private final java.lang.String clusterName

edsServiceName

@Nullable
private final java.lang.String edsServiceName

uncategorizedDrops

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

categorizedDrops

private final java.util.concurrent.ConcurrentMap<java.lang.String,java.util.concurrent.atomic.AtomicLong> categorizedDrops

stopwatch

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

Constructor Detail

ClusterDropStats

private ClusterDropStats(java.lang.String clusterName,
                         @Nullable
                         java.lang.String edsServiceName,
                         com.google.common.base.Stopwatch stopwatch)

Method Detail

recordDroppedRequest

public void recordDroppedRequest(java.lang.String category)

Records a dropped request with the specified category.

recordDroppedRequest

public void recordDroppedRequest()

Records a dropped request without category.

release

public void release()

Release the hard reference for this stats object (previously obtained via LoadStatsManager2.getClusterDropStats(java.lang.String, java.lang.String)). The object may still be recording drops after this method, but there is no guarantee drops recorded after this point will be included in load reports.

snapshot

private LoadStatsManager2.ClusterDropStatsSnapshot snapshot()