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

Modifier and Type	Method	Description
XdsClient	getObject()
java.lang.String	getTarget()
(package private) XdsClient	getXdsClientForTest()
XdsClient	returnObject(java.lang.Object object)

Methods inherited from class java.lang.Object

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

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 interface io.grpc.internal.ObjectPool<XdsClient>

returnObject

public XdsClient returnObject(java.lang.Object object)

Specified by:

returnObject in interface io.grpc.internal.ObjectPool<XdsClient>

getXdsClientForTest

@Nullable
XdsClient getXdsClientForTest()

getTarget

public java.lang.String getTarget()