Class XdsClientImpl

java.lang.Object

io.grpc.xds.client.XdsClient

io.grpc.xds.client.XdsClientImpl

All Implemented Interfaces:

XdsClient.ResourceStore

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

XdsClient implementation.

Nested Class Summary

Nested classes/interfaces inherited from class XdsClient

XdsClient.ResourceMetadata, XdsClient.ResourceStore, XdsClient.ResourceUpdate, XdsClient.ResourceWatcher<T>

Field Summary

Fields

Modifier and Type	Field	Description
static final int	INITIAL_RESOURCE_FETCH_TIMEOUT_SEC

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.
Bootstrapper.BootstrapInfo	getBootstrapInfo()	Returns the config used to bootstrap this XdsClient Bootstrapper.BootstrapInfo.
io.grpc.xds.client.ControlPlaneClient	getOrCreateControlPlaneClient(Bootstrapper.ServerInfo serverInfo)
Object	getSecurityConfig()	Returns the implementation specific security configuration used in this XdsClient.
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, io.grpc.xds.client.XdsClient.ProcessingTracker processingTracker)
void	handleStreamClosed(io.grpc.Status error)
void	handleStreamRestarted(Bootstrapper.ServerInfo serverInfo)
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 XdsClient

canonifyResourceName, isResourceNameValid, percentEncodePath, watchXdsResource

Methods inherited from class 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

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,
 io.grpc.xds.client.XdsClient.ProcessingTracker processingTracker)

handleStreamClosed

public void handleStreamClosed(io.grpc.Status error)

handleStreamRestarted

public void handleStreamRestarted(Bootstrapper.ServerInfo serverInfo)

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

getOrCreateControlPlaneClient

public io.grpc.xds.client.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