(package private) void |
ControlPlaneClient.ackResponse(XdsResourceType<?> type,
java.lang.String versionInfo,
java.lang.String nonce) |
Accepts the update for the given resource type by updating the latest resource version
and sends an ACK request to the management server.
|
(package private) void |
ControlPlaneClient.adjustResourceSubscription(XdsResourceType<?> resourceType) |
Updates the resource subscription for the given resource type.
|
<T extends XdsClient.ResourceUpdate> void |
XdsClient.cancelXdsResourceWatch(XdsResourceType<T> type,
java.lang.String resourceName,
XdsClient.ResourceWatcher<T> watcher) |
Unregisters the given resource watcher.
|
<T extends XdsClient.ResourceUpdate> void |
XdsClientImpl.cancelXdsResourceWatch(XdsResourceType<T> type,
java.lang.String resourceName,
XdsClient.ResourceWatcher<T> watcher) |
|
private java.util.Set<java.lang.String> |
XdsClientImpl.getResourceKeys(XdsResourceType<?> xdsResourceType) |
|
java.util.Collection<java.lang.String> |
XdsClient.ResourceStore.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.
|
java.util.Collection<java.lang.String> |
XdsClientImpl.getSubscribedResources(Bootstrapper.ServerInfo serverInfo,
XdsResourceType<? extends XdsClient.ResourceUpdate> type) |
|
void |
XdsClient.XdsResponseHandler.handleResourceResponse(XdsResourceType<?> resourceType,
Bootstrapper.ServerInfo serverInfo,
java.lang.String versionInfo,
java.util.List<com.google.protobuf.Any> resources,
java.lang.String nonce,
XdsClient.ProcessingTracker processingTracker) |
Called when a xds response is received.
|
void |
XdsClientImpl.handleResourceResponse(XdsResourceType<?> xdsResourceType,
Bootstrapper.ServerInfo serverInfo,
java.lang.String versionInfo,
java.util.List<com.google.protobuf.Any> resources,
java.lang.String nonce,
XdsClient.ProcessingTracker processingTracker) |
|
private <T extends XdsClient.ResourceUpdate> void |
XdsClientImpl.handleResourceUpdate(XdsResourceType.Args args,
java.util.List<com.google.protobuf.Any> resources,
XdsResourceType<T> xdsResourceType,
XdsClient.ProcessingTracker processingTracker) |
|
(package private) void |
ControlPlaneClient.AdsStream.handleRpcResponse(XdsResourceType<?> type,
java.lang.String versionInfo,
java.util.List<com.google.protobuf.Any> resources,
java.lang.String nonce) |
|
(package private) void |
ControlPlaneClient.nackResponse(XdsResourceType<?> type,
java.lang.String nonce,
java.lang.String errorDetail) |
Rejects the update for the given resource type and sends an NACK request (request with last
accepted version) to the management server.
|
(package private) void |
ControlPlaneClient.AdsStream.sendDiscoveryRequest(XdsResourceType<?> type,
java.lang.String versionInfo,
java.util.Collection<java.lang.String> resources,
java.lang.String nonce,
java.lang.String errorDetail) |
Sends a discovery request with the given versionInfo , nonce and
errorDetail .
|
(package private) void |
ControlPlaneClient.AdsStream.sendDiscoveryRequest(XdsResourceType<?> type,
java.util.Collection<java.lang.String> resources) |
Sends a client-initiated discovery request.
|
<T extends XdsClient.ResourceUpdate> void |
XdsClient.watchXdsResource(XdsResourceType<T> type,
java.lang.String resourceName,
XdsClient.ResourceWatcher<T> watcher) |
|
<T extends XdsClient.ResourceUpdate> void |
XdsClient.watchXdsResource(XdsResourceType<T> type,
java.lang.String resourceName,
XdsClient.ResourceWatcher<T> watcher,
java.util.concurrent.Executor executor) |
Registers a data watcher for the given Xds resource.
|
<T extends XdsClient.ResourceUpdate> void |
XdsClientImpl.watchXdsResource(XdsResourceType<T> type,
java.lang.String resourceName,
XdsClient.ResourceWatcher<T> watcher,
java.util.concurrent.Executor watcherExecutor) |
|