SharedXdsClientPoolProvider

java.lang.Object

io.grpc.xds.SharedXdsClientPoolProvider

All Implemented Interfaces:: XdsClientPoolFactory

@ThreadSafe final class SharedXdsClientPoolProvider extends Object implements XdsClientPoolFactory

The global factory for creating a singleton XdsClient instance to be used by all gRPC clients in the process.

Nested Class Summary

Nested Classes

Modifier and Type

Class

Description

(package private) static class

SharedXdsClientPoolProvider.RefCountedXdsClientObjectPool

private static class

SharedXdsClientPoolProvider.SharedXdsClientPoolProviderHolder
Field Summary

Fields

Modifier and Type

Field

Description

private final AtomicReference<Map<String,?>>

bootstrapOverride

private final Bootstrapper

bootstrapper

private final Object

lock

private static final Logger

log

private static final boolean

LOG_XDS_NODE_ID

private final Map<String,io.grpc.internal.ObjectPool<XdsClient>>

targetToXdsClientMap
Constructor Summary

Constructors

Constructor

Description

SharedXdsClientPoolProvider()

SharedXdsClientPoolProvider(Bootstrapper bootstrapper)
Method Summary

Modifier and Type

Method

Description

io.grpc.internal.ObjectPool<XdsClient>

get(String target)

(package private) static SharedXdsClientPoolProvider

getDefaultProvider()

io.grpc.internal.ObjectPool<XdsClient>

getOrCreate(String target)

com.google.common.collect.ImmutableList<String>

getTargets()

void

setBootstrapOverride(Map<String,?> bootstrap)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- LOG_XDS_NODE_ID
  
  private static final boolean LOG_XDS_NODE_ID
- log
  
  private static final Logger log
- bootstrapper
  
  private final Bootstrapper bootstrapper
- lock
  
  private final Object lock
- bootstrapOverride
  
  private final AtomicReference<Map<String,?>> bootstrapOverride
- targetToXdsClientMap
  
  private final Map<String,io.grpc.internal.ObjectPool<XdsClient>> targetToXdsClientMap
Constructor Details
- SharedXdsClientPoolProvider
  
  SharedXdsClientPoolProvider()
- SharedXdsClientPoolProvider
  
  SharedXdsClientPoolProvider(Bootstrapper bootstrapper)
Method Details
- getDefaultProvider
  
  static SharedXdsClientPoolProvider getDefaultProvider()
- setBootstrapOverride
  
  public void setBootstrapOverride(Map<String,?> bootstrap)
  
  Specified by:
  
  setBootstrapOverride in interface XdsClientPoolFactory
- get
  
  @Nullable public io.grpc.internal.ObjectPool<XdsClient> get(String target)
  
  Specified by:
  
  get in interface XdsClientPoolFactory
- getOrCreate
  
  public io.grpc.internal.ObjectPool<XdsClient> getOrCreate(String target) throws XdsInitializationException
  
  Specified by:
  
  getOrCreate in interface XdsClientPoolFactory
  
  Throws:
  
  XdsInitializationException
- getTargets
  
  public com.google.common.collect.ImmutableList<String> getTargets()
  
  Specified by:
  
  getTargets in interface XdsClientPoolFactory