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

Fields

Modifier and Type	Field	Description
private boolean	absent
private final ControlPlaneClient	controlPlaneClient
private T	data
private String	errorDescription
private XdsClient.ResourceMetadata	metadata
private final String	resource
private boolean	resourceDeletionIgnored
private io.grpc.SynchronizationContext.ScheduledHandle	respTimer
private final Bootstrapper.ServerInfo	serverInfo
private final XdsResourceType<T>	type
private final Map<XdsClient.ResourceWatcher<T>,Executor>	watchers

Constructor Summary

Constructors

Constructor	Description
ResourceSubscriber(XdsResourceType<T> type, String resource)

Method Summary

Modifier and Type	Method	Description
(package private) void	addWatcher(XdsClient.ResourceWatcher<T> watcher, 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, 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	restartTimer()
(package private) void	stopTimer()

Methods inherited from class java.lang.Object

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

Field Details

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 String resource

watchers

private final Map<XdsClient.ResourceWatcher<T extends XdsClient.ResourceUpdate>,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 String errorDescription

Constructor Details

ResourceSubscriber

ResourceSubscriber(XdsResourceType<T> type,
 String resource)

Method Details

addWatcher

void addWatcher(XdsClient.ResourceWatcher<T> watcher,
 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,
 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(String rejectedVersion,
 long rejectedTime,
 String rejectedDetails)

notifyWatcher

private void notifyWatcher(XdsClient.ResourceWatcher<T> watcher,
 T update)