Package io.grpc.xds.client

Class XdsClientImpl

java.lang.Object

io.grpc.xds.client.XdsClient

io.grpc.xds.client.XdsClientImpl

All Implemented Interfaces:

XdsClient.ResourceStore, XdsClient.XdsResponseHandler

@Internal
public final class XdsClientImpl
extends XdsClient
implements XdsClient.XdsResponseHandler, XdsClient.ResourceStore

XdsClient implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	XdsClientImpl.ResourceSubscriber<T extends XdsClient.ResourceUpdate>	Tracks a single subscribed resource.

Nested classes/interfaces inherited from class io.grpc.xds.client.XdsClient

XdsClient.ProcessingTracker, XdsClient.ResourceMetadata, XdsClient.ResourceStore, XdsClient.ResourceUpdate, XdsClient.ResourceWatcher<T extends XdsClient.ResourceUpdate>, XdsClient.XdsResponseHandler

Field Summary

Fields

Modifier and Type	Field	Description
private final io.grpc.internal.BackoffPolicy.Provider	backoffPolicyProvider
private final Bootstrapper.BootstrapInfo	bootstrapInfo
static final int	INITIAL_RESOURCE_FETCH_TIMEOUT_SEC
private boolean	isShutdown
private final Map<Bootstrapper.ServerInfo,LoadStatsManager2>	loadStatsManagerMap
private final XdsLogger	logger
private final io.grpc.InternalLogId	logId
private final MessagePrettyPrinter	messagePrinter
private final Map<XdsResourceType<? extends XdsClient.ResourceUpdate>,Map<String,XdsClientImpl.ResourceSubscriber<? extends XdsClient.ResourceUpdate>>>	resourceSubscribers
private final Object	securityConfig
private final Map<Bootstrapper.ServerInfo,ControlPlaneClient>	serverCpClientMap
(package private) final Map<Bootstrapper.ServerInfo,LoadReportClient>	serverLrsClientMap
private final com.google.common.base.Supplier<com.google.common.base.Stopwatch>	stopwatchSupplier
private final Map<String,XdsResourceType<?>>	subscribedResourceTypeUrls
private final io.grpc.SynchronizationContext	syncContext
private final io.grpc.internal.TimeProvider	timeProvider
private final ScheduledExecutorService	timeService
private final XdsTransportFactory	xdsTransportFactory

Constructor Summary

Constructors

Constructor	Description
XdsClientImpl(XdsTransportFactory xdsTransportFactory, Bootstrapper.BootstrapInfo bootstrapInfo, ScheduledExecutorService timeService, io.grpc.internal.BackoffPolicy.Provider backoffPolicyProvider, com.google.common.base.Supplier<com.google.common.base.Stopwatch> stopwatchSupplier, io.grpc.internal.TimeProvider timeProvider, MessagePrettyPrinter messagePrinter, Object securityConfig)

Method Summary

Modifier and Type	Method	Description
LoadStatsManager2.ClusterDropStats	addClusterDropStats(Bootstrapper.ServerInfo serverInfo, String clusterName, String edsServiceName)	Adds drop stats for the specified cluster with edsServiceName by using the returned object to record dropped requests.
LoadStatsManager2.ClusterLocalityStats	addClusterLocalityStats(Bootstrapper.ServerInfo serverInfo, String clusterName, String edsServiceName, Locality locality)	Adds load stats for the specified locality (in the specified cluster with edsServiceName) by using the returned object to record RPCs.
<T extends XdsClient.ResourceUpdate> void	cancelXdsResourceWatch(XdsResourceType<T> type, String resourceName, XdsClient.ResourceWatcher<T> watcher)	Unregisters the given resource watcher.
private void	cleanUpResourceTimers()
Bootstrapper.BootstrapInfo	getBootstrapInfo()	Returns the config used to bootstrap this XdsClient Bootstrapper.BootstrapInfo.
ControlPlaneClient	getOrCreateControlPlaneClient(Bootstrapper.ServerInfo serverInfo)
private Set<String>	getResourceKeys(XdsResourceType<?> xdsResourceType)
Object	getSecurityConfig()	Returns the implementation specific security configuration used in this XdsClient.
private Bootstrapper.ServerInfo	getServerInfo(String resource)
Map<Bootstrapper.ServerInfo,LoadReportClient>	getServerLrsClientMap()	Returns a map of control plane server info objects to the LoadReportClients that are responsible for sending load reports to the control plane servers.
Collection<String>	getSubscribedResources(Bootstrapper.ServerInfo serverInfo, XdsResourceType<? extends XdsClient.ResourceUpdate> type)	Returns the collection of resources currently subscribing to or null if not subscribing to any resources for the given type.
com.google.common.util.concurrent.ListenableFuture<Map<XdsResourceType<?>,Map<String,XdsClient.ResourceMetadata>>>	getSubscribedResourcesMetadataSnapshot()	Returns a ListenableFuture to the snapshot of the subscribed resources as they are at the moment of the call.
Map<String,XdsResourceType<?>>	getSubscribedResourceTypesWithTypeUrl()
void	handleResourceResponse(XdsResourceType<?> xdsResourceType, Bootstrapper.ServerInfo serverInfo, String versionInfo, List<com.google.protobuf.Any> resources, String nonce, XdsClient.ProcessingTracker processingTracker)	Called when a xds response is received.
private <T extends XdsClient.ResourceUpdate> void	handleResourceUpdate(XdsResourceType.Args args, List<com.google.protobuf.Any> resources, XdsResourceType<T> xdsResourceType, XdsClient.ProcessingTracker processingTracker)
void	handleStreamClosed(io.grpc.Status error)	Called when the ADS stream is closed passively.
void	handleStreamRestarted(Bootstrapper.ServerInfo serverInfo)	Called when the ADS stream has been recreated.
boolean	isShutDown()	Returns true if XdsClient.shutdown() has been called.
void	shutdown()	Shutdown this XdsClient and release resources.
protected void	startSubscriberTimersIfNeeded(Bootstrapper.ServerInfo serverInfo)	For all subscriber's for the specified server, if the resource hasn't yet been resolved then start a timer for it.
String	toString()
<T extends XdsClient.ResourceUpdate> void	watchXdsResource(XdsResourceType<T> type, String resourceName, XdsClient.ResourceWatcher<T> watcher, Executor watcherExecutor)	Registers a data watcher for the given Xds resource.

Methods inherited from class io.grpc.xds.client.XdsClient

canonifyResourceName, isResourceNameValid, percentEncodePath, watchXdsResource

Methods inherited from class java.lang.Object

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

Field Details

INITIAL_RESOURCE_FETCH_TIMEOUT_SEC

public static final int INITIAL_RESOURCE_FETCH_TIMEOUT_SEC

See Also:

• Constant Field Values

syncContext

private final io.grpc.SynchronizationContext syncContext

loadStatsManagerMap

private final Map<Bootstrapper.ServerInfo,LoadStatsManager2> loadStatsManagerMap

serverLrsClientMap

final Map<Bootstrapper.ServerInfo,LoadReportClient> serverLrsClientMap

serverCpClientMap

private final Map<Bootstrapper.ServerInfo,ControlPlaneClient> serverCpClientMap

resourceSubscribers

private final Map<XdsResourceType<? extends XdsClient.ResourceUpdate>,Map<String,XdsClientImpl.ResourceSubscriber<? extends XdsClient.ResourceUpdate>>> resourceSubscribers

subscribedResourceTypeUrls

private final Map<String,XdsResourceType<?>> subscribedResourceTypeUrls

xdsTransportFactory

private final XdsTransportFactory xdsTransportFactory

bootstrapInfo

private final Bootstrapper.BootstrapInfo bootstrapInfo

timeService

private final ScheduledExecutorService timeService

backoffPolicyProvider

private final io.grpc.internal.BackoffPolicy.Provider backoffPolicyProvider

stopwatchSupplier

private final com.google.common.base.Supplier<com.google.common.base.Stopwatch> stopwatchSupplier

timeProvider

private final io.grpc.internal.TimeProvider timeProvider

securityConfig

private final Object securityConfig

logId

private final io.grpc.InternalLogId logId

logger

private final XdsLogger logger

isShutdown

private volatile boolean isShutdown

messagePrinter

private final MessagePrettyPrinter messagePrinter

Constructor Details

XdsClientImpl

public XdsClientImpl(XdsTransportFactory xdsTransportFactory,
 Bootstrapper.BootstrapInfo bootstrapInfo,
 ScheduledExecutorService timeService,
 io.grpc.internal.BackoffPolicy.Provider backoffPolicyProvider,
 com.google.common.base.Supplier<com.google.common.base.Stopwatch> stopwatchSupplier,
 io.grpc.internal.TimeProvider timeProvider,
 MessagePrettyPrinter messagePrinter,
 Object securityConfig)

Method Details

handleResourceResponse

public void handleResourceResponse(XdsResourceType<?> xdsResourceType,
 Bootstrapper.ServerInfo serverInfo,
 String versionInfo,
 List<com.google.protobuf.Any> resources,
 String nonce,
 XdsClient.ProcessingTracker processingTracker)

Description copied from interface: XdsClient.XdsResponseHandler

Called when a xds response is received.

Specified by:

handleResourceResponse in interface XdsClient.XdsResponseHandler

handleStreamClosed

public void handleStreamClosed(io.grpc.Status error)

Description copied from interface: XdsClient.XdsResponseHandler

Called when the ADS stream is closed passively.

Specified by:

handleStreamClosed in interface XdsClient.XdsResponseHandler

handleStreamRestarted

public void handleStreamRestarted(Bootstrapper.ServerInfo serverInfo)

Description copied from interface: XdsClient.XdsResponseHandler

Called when the ADS stream has been recreated.

Specified by:

handleStreamRestarted in interface XdsClient.XdsResponseHandler

shutdown

public void shutdown()

Description copied from class: XdsClient

Shutdown this XdsClient and release resources.

Overrides:

shutdown in class XdsClient

isShutDown

public boolean isShutDown()

Description copied from class: XdsClient

Returns true if XdsClient.shutdown() has been called.

Overrides:

isShutDown in class XdsClient

getSubscribedResourceTypesWithTypeUrl

public Map<String,XdsResourceType<?>> getSubscribedResourceTypesWithTypeUrl()

Specified by:

getSubscribedResourceTypesWithTypeUrl in interface XdsClient.ResourceStore

getSubscribedResources

@Nullable
public Collection<String> getSubscribedResources(Bootstrapper.ServerInfo serverInfo,
 XdsResourceType<? extends XdsClient.ResourceUpdate> type)

Description copied from interface: XdsClient.ResourceStore

Returns the collection of resources currently subscribing to or null if not subscribing to any resources for the given type.

Note an empty collection indicates subscribing to resources of the given type with wildcard mode.

Specified by:

getSubscribedResources in interface XdsClient.ResourceStore

getSubscribedResourcesMetadataSnapshot

public com.google.common.util.concurrent.ListenableFuture<Map<XdsResourceType<?>,Map<String,XdsClient.ResourceMetadata>>> getSubscribedResourcesMetadataSnapshot()

Description copied from class: XdsClient

Returns a ListenableFuture to the snapshot of the subscribed resources as they are at the moment of the call.

The snapshot is a map from the "resource type" to a map ("resource name": "resource metadata").

Overrides:

getSubscribedResourcesMetadataSnapshot in class XdsClient

getSecurityConfig

public Object getSecurityConfig()

Description copied from class: XdsClient

Returns the implementation specific security configuration used in this XdsClient.

Overrides:

getSecurityConfig in class XdsClient

watchXdsResource

public <T extends XdsClient.ResourceUpdate> void watchXdsResource(XdsResourceType<T> type,
 String resourceName,
 XdsClient.ResourceWatcher<T> watcher,
 Executor watcherExecutor)

Description copied from class: XdsClient

Registers a data watcher for the given Xds resource.

Overrides:

watchXdsResource in class XdsClient

cancelXdsResourceWatch

public <T extends XdsClient.ResourceUpdate> void cancelXdsResourceWatch(XdsResourceType<T> type,
 String resourceName,
 XdsClient.ResourceWatcher<T> watcher)

Description copied from class: XdsClient

Unregisters the given resource watcher.

Overrides:

cancelXdsResourceWatch in class XdsClient

addClusterDropStats

public LoadStatsManager2.ClusterDropStats addClusterDropStats(Bootstrapper.ServerInfo serverInfo,
 String clusterName,
 @Nullable
 String edsServiceName)

Description copied from class: XdsClient

Adds drop stats for the specified cluster with edsServiceName by using the returned object to record dropped requests. Drop stats recorded with the returned object will be reported to the load reporting server. The returned object is reference counted and the caller should use LoadStatsManager2.ClusterDropStats.release() to release its hard reference when it is safe to stop reporting dropped RPCs for the specified cluster in the future.

Overrides:

addClusterDropStats in class XdsClient

addClusterLocalityStats

public LoadStatsManager2.ClusterLocalityStats addClusterLocalityStats(Bootstrapper.ServerInfo serverInfo,
 String clusterName,
 @Nullable
 String edsServiceName,
 Locality locality)

Description copied from class: XdsClient

Adds load stats for the specified locality (in the specified cluster with edsServiceName) by using the returned object to record RPCs. Load stats recorded with the returned object will be reported to the load reporting server. The returned object is reference counted and the caller should use LoadStatsManager2.ClusterLocalityStats.release() to release its hard reference when it is safe to stop reporting RPC loads for the specified locality in the future.

Overrides:

addClusterLocalityStats in class XdsClient

getBootstrapInfo

public Bootstrapper.BootstrapInfo getBootstrapInfo()

Description copied from class: XdsClient

Returns the config used to bootstrap this XdsClient Bootstrapper.BootstrapInfo.

Overrides:

getBootstrapInfo in class XdsClient

toString

public String toString()

Overrides:

toString in class Object

startSubscriberTimersIfNeeded

protected void startSubscriberTimersIfNeeded(Bootstrapper.ServerInfo serverInfo)

Description copied from class: XdsClient

For all subscriber's for the specified server, if the resource hasn't yet been resolved then start a timer for it.

Overrides:

startSubscriberTimersIfNeeded in class XdsClient

getResourceKeys

private Set<String> getResourceKeys(XdsResourceType<?> xdsResourceType)

cleanUpResourceTimers

private void cleanUpResourceTimers()

getOrCreateControlPlaneClient

public ControlPlaneClient getOrCreateControlPlaneClient(Bootstrapper.ServerInfo serverInfo)

getServerLrsClientMap

public Map<Bootstrapper.ServerInfo,LoadReportClient> getServerLrsClientMap()

Description copied from class: XdsClient

Returns a map of control plane server info objects to the LoadReportClients that are responsible for sending load reports to the control plane servers.

Overrides:

getServerLrsClientMap in class XdsClient

getServerInfo

@Nullable
private Bootstrapper.ServerInfo getServerInfo(String resource)

handleResourceUpdate

private <T extends XdsClient.ResourceUpdate> void handleResourceUpdate(XdsResourceType.Args args,
 List<com.google.protobuf.Any> resources,
 XdsResourceType<T> xdsResourceType,
 XdsClient.ProcessingTracker processingTracker)