Package io.grpc.xds.client
Class XdsClientImpl.ResourceSubscriber<T extends XdsClient.ResourceUpdate>
java.lang.Object
io.grpc.xds.client.XdsClientImpl.ResourceSubscriber<T>
- Enclosing class:
XdsClientImpl
private final class XdsClientImpl.ResourceSubscriber<T extends XdsClient.ResourceUpdate>
extends Object
Tracks a single subscribed resource.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate boolean
private final ControlPlaneClient
private T
private String
private XdsClient.ResourceMetadata
private final String
private boolean
private io.grpc.SynchronizationContext.ScheduledHandle
private final Bootstrapper.ServerInfo
private final XdsResourceType
<T> private final Map
<XdsClient.ResourceWatcher<T>, Executor> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) void
addWatcher
(XdsClient.ResourceWatcher<T> watcher, Executor watcherExecutor) (package private) void
(package private) boolean
(package private) boolean
private void
notifyWatcher
(XdsClient.ResourceWatcher<T> watcher, T update) (package private) void
onAbsent
(XdsClient.ProcessingTracker processingTracker) (package private) void
onData
(XdsResourceType.ParsedResource<T> parsedResource, String version, long updateTime, XdsClient.ProcessingTracker processingTracker) (package private) void
onError
(io.grpc.Status error, XdsClient.ProcessingTracker tracker) (package private) void
onRejected
(String rejectedVersion, long rejectedTime, String rejectedDetails) (package private) void
removeWatcher
(XdsClient.ResourceWatcher<T> watcher) (package private) void
(package private) void
-
Field Details
-
serverInfo
-
controlPlaneClient
-
type
-
resource
-
watchers
-
data
-
absent
private boolean absent -
resourceDeletionIgnored
private boolean resourceDeletionIgnored -
respTimer
-
metadata
-
errorDescription
-
-
Constructor Details
-
ResourceSubscriber
ResourceSubscriber(XdsResourceType<T> type, String resource)
-
-
Method Details
-
addWatcher
-
removeWatcher
-
restartTimer
void restartTimer() -
stopTimer
void stopTimer() -
cancelResourceWatch
void cancelResourceWatch() -
isWatched
boolean isWatched() -
hasResult
boolean hasResult() -
onData
void onData(XdsResourceType.ParsedResource<T> parsedResource, String version, long updateTime, XdsClient.ProcessingTracker processingTracker) -
onAbsent
-
onError
-
onRejected
-
notifyWatcher
-