Package io.grpc.xds
Class SharedXdsClientPoolProvider.RefCountedXdsClientObjectPool
- java.lang.Object
-
- io.grpc.xds.SharedXdsClientPoolProvider.RefCountedXdsClientObjectPool
-
- All Implemented Interfaces:
io.grpc.internal.ObjectPool<XdsClient>
- Enclosing class:
- SharedXdsClientPoolProvider
@ThreadSafe static class SharedXdsClientPoolProvider.RefCountedXdsClientObjectPool extends java.lang.Object implements io.grpc.internal.ObjectPool<XdsClient>
-
-
Field Summary
Fields Modifier and Type Field Description private static io.grpc.internal.ExponentialBackoffPolicy.Provider
BACKOFF_POLICY_PROVIDER
private Bootstrapper.BootstrapInfo
bootstrapInfo
private java.lang.Object
lock
private int
refCount
private java.util.concurrent.ScheduledExecutorService
scheduler
private java.lang.String
target
private XdsClient
xdsClient
-
Constructor Summary
Constructors Constructor Description RefCountedXdsClientObjectPool(Bootstrapper.BootstrapInfo bootstrapInfo, java.lang.String target)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description XdsClient
getObject()
java.lang.String
getTarget()
(package private) XdsClient
getXdsClientForTest()
XdsClient
returnObject(java.lang.Object object)
-
-
-
Field Detail
-
BACKOFF_POLICY_PROVIDER
private static final io.grpc.internal.ExponentialBackoffPolicy.Provider BACKOFF_POLICY_PROVIDER
-
bootstrapInfo
private final Bootstrapper.BootstrapInfo bootstrapInfo
-
target
private final java.lang.String target
-
lock
private final java.lang.Object lock
-
scheduler
private java.util.concurrent.ScheduledExecutorService scheduler
-
xdsClient
private XdsClient xdsClient
-
refCount
private int refCount
-
-
Constructor Detail
-
RefCountedXdsClientObjectPool
RefCountedXdsClientObjectPool(Bootstrapper.BootstrapInfo bootstrapInfo, java.lang.String target)
-
-
Method Detail
-
getObject
public XdsClient getObject()
- Specified by:
getObject
in interfaceio.grpc.internal.ObjectPool<XdsClient>
-
returnObject
public XdsClient returnObject(java.lang.Object object)
- Specified by:
returnObject
in interfaceio.grpc.internal.ObjectPool<XdsClient>
-
getXdsClientForTest
@Nullable XdsClient getXdsClientForTest()
-
getTarget
public java.lang.String getTarget()
-
-