Package io.grpc.xds
Class SharedCallCounterMap
java.lang.Object
io.grpc.xds.SharedCallCounterMap
- All Implemented Interfaces:
XdsNameResolverProvider.CallCounterProvider
@ThreadSafe
final class SharedCallCounterMap
extends Object
implements XdsNameResolverProvider.CallCounterProvider
The global map for holding circuit breaker atomic counters.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
private static final class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final Map
<String, Map<String, SharedCallCounterMap.CounterReference>> private final ReferenceQueue
<AtomicLong> -
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
(package private)
-
Method Summary
Modifier and TypeMethodDescription(package private) void
(package private) static SharedCallCounterMap
getOrCreate
(String cluster, String edsServiceName)
-
Field Details
-
refQueue
-
counters
-
-
Constructor Details
-
SharedCallCounterMap
private SharedCallCounterMap() -
SharedCallCounterMap
SharedCallCounterMap(Map<String, Map<String, SharedCallCounterMap.CounterReference>> counters)
-
-
Method Details
-
getInstance
-
getOrCreate
- Specified by:
getOrCreate
in interfaceXdsNameResolverProvider.CallCounterProvider
-
cleanQueue
void cleanQueue()
-