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 java.lang.Object
Tracks a single subscribed resource.
-
-
Field Summary
Fields Modifier and Type Field Description private boolean
absent
private ControlPlaneClient
controlPlaneClient
private T
data
private java.lang.String
errorDescription
private XdsClient.ResourceMetadata
metadata
private java.lang.String
resource
private boolean
resourceDeletionIgnored
private io.grpc.SynchronizationContext.ScheduledHandle
respTimer
private Bootstrapper.ServerInfo
serverInfo
private XdsResourceType<T>
type
private java.util.Map<XdsClient.ResourceWatcher<T>,java.util.concurrent.Executor>
watchers
-
Constructor Summary
Constructors Constructor Description ResourceSubscriber(XdsResourceType<T> type, java.lang.String resource)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
addWatcher(XdsClient.ResourceWatcher<T> watcher, java.util.concurrent.Executor watcherExecutor)
(package private) void
cancelResourceWatch()
(package private) boolean
hasResult()
(package private) boolean
isWatched()
private void
notifyWatcher(XdsClient.ResourceWatcher<T> watcher, T update)
(package private) void
onAbsent(XdsClient.ProcessingTracker processingTracker)
(package private) void
onData(XdsResourceType.ParsedResource<T> parsedResource, java.lang.String version, long updateTime, XdsClient.ProcessingTracker processingTracker)
(package private) void
onError(io.grpc.Status error, XdsClient.ProcessingTracker tracker)
(package private) void
onRejected(java.lang.String rejectedVersion, long rejectedTime, java.lang.String rejectedDetails)
(package private) void
removeWatcher(XdsClient.ResourceWatcher<T> watcher)
(package private) void
restartTimer()
(package private) void
stopTimer()
-
-
-
Field Detail
-
serverInfo
@Nullable private final Bootstrapper.ServerInfo serverInfo
-
controlPlaneClient
@Nullable private final ControlPlaneClient controlPlaneClient
-
type
private final XdsResourceType<T extends XdsClient.ResourceUpdate> type
-
resource
private final java.lang.String resource
-
watchers
private final java.util.Map<XdsClient.ResourceWatcher<T extends XdsClient.ResourceUpdate>,java.util.concurrent.Executor> watchers
-
data
@Nullable private T extends XdsClient.ResourceUpdate data
-
absent
private boolean absent
-
resourceDeletionIgnored
private boolean resourceDeletionIgnored
-
respTimer
@Nullable private io.grpc.SynchronizationContext.ScheduledHandle respTimer
-
metadata
@Nullable private XdsClient.ResourceMetadata metadata
-
errorDescription
@Nullable private java.lang.String errorDescription
-
-
Constructor Detail
-
ResourceSubscriber
ResourceSubscriber(XdsResourceType<T> type, java.lang.String resource)
-
-
Method Detail
-
addWatcher
void addWatcher(XdsClient.ResourceWatcher<T> watcher, java.util.concurrent.Executor watcherExecutor)
-
removeWatcher
void removeWatcher(XdsClient.ResourceWatcher<T> watcher)
-
restartTimer
void restartTimer()
-
stopTimer
void stopTimer()
-
cancelResourceWatch
void cancelResourceWatch()
-
isWatched
boolean isWatched()
-
hasResult
boolean hasResult()
-
onData
void onData(XdsResourceType.ParsedResource<T> parsedResource, java.lang.String version, long updateTime, XdsClient.ProcessingTracker processingTracker)
-
onAbsent
void onAbsent(@Nullable XdsClient.ProcessingTracker processingTracker)
-
onError
void onError(io.grpc.Status error, @Nullable XdsClient.ProcessingTracker tracker)
-
onRejected
void onRejected(java.lang.String rejectedVersion, long rejectedTime, java.lang.String rejectedDetails)
-
notifyWatcher
private void notifyWatcher(XdsClient.ResourceWatcher<T> watcher, T update)
-
-