Package io.grpc.xds

Class XdsNameResolver.ResolveState

java.lang.Object

io.grpc.xds.XdsNameResolver.ResolveState

All Implemented Interfaces:

XdsClient.ResourceWatcher<XdsListenerResource.LdsUpdate>

Enclosing class:

XdsNameResolver

private class XdsNameResolver.ResolveState
extends Object
implements XdsClient.ResourceWatcher<XdsListenerResource.LdsUpdate>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	XdsNameResolver.ResolveState.RouteDiscoveryState	Discovery state for RouteConfiguration resource.

Field Summary

Fields

Modifier and Type	Field	Description
private final io.grpc.NameResolver.ConfigOrError	emptyServiceConfig
private Set<String>	existingClusters
private final String	ldsResourceName
private XdsNameResolver.ResolveState.RouteDiscoveryState	routeDiscoveryState
private boolean	stopped

Constructor Summary

Constructors

Constructor	Description
ResolveState(String ldsResourceName)

Method Summary

Modifier and Type	Method	Description
private void	cleanUpRouteDiscoveryState()
private void	cleanUpRoutes(String error)
void	onChanged(XdsListenerResource.LdsUpdate update)
void	onError(io.grpc.Status error)	Called when the resource discovery RPC encounters some transient error.
void	onResourceDoesNotExist(String resourceName)	Called when the requested resource is not available.
private void	start()
private void	stop()
private void	updateRoutes(List<VirtualHost> virtualHosts, long httpMaxStreamDurationNano, List<Filter.NamedFilterConfig> filterConfigs)

Methods inherited from class java.lang.Object

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

Field Details

emptyServiceConfig

private final io.grpc.NameResolver.ConfigOrError emptyServiceConfig

ldsResourceName

private final String ldsResourceName

stopped

private boolean stopped

existingClusters

@Nullable
private Set<String> existingClusters

routeDiscoveryState

@Nullable
private XdsNameResolver.ResolveState.RouteDiscoveryState routeDiscoveryState

Constructor Details

ResolveState

ResolveState(String ldsResourceName)

Method Details

onChanged

public void onChanged(XdsListenerResource.LdsUpdate update)

Specified by:

onChanged in interface XdsClient.ResourceWatcher<XdsListenerResource.LdsUpdate>

onError

public void onError(io.grpc.Status error)

Description copied from interface: XdsClient.ResourceWatcher

Called when the resource discovery RPC encounters some transient error.

Note that we expect that the implementer to: - Comply with the guarantee to not generate certain statuses by the library: https://grpc.github.io/grpc/core/md_doc_statuscodes.html. If the code needs to be propagated to the channel, override it with Status.Code.UNAVAILABLE. - Keep Status description in one form or another, as it contains valuable debugging information.

Specified by:

onError in interface XdsClient.ResourceWatcher<XdsListenerResource.LdsUpdate>

onResourceDoesNotExist

public void onResourceDoesNotExist(String resourceName)

Description copied from interface: XdsClient.ResourceWatcher

Called when the requested resource is not available.

Specified by:

onResourceDoesNotExist in interface XdsClient.ResourceWatcher<XdsListenerResource.LdsUpdate>

Parameters:

resourceName - name of the resource requested in discovery request.

start

private void start()

stop

private void stop()

updateRoutes

private void updateRoutes(List<VirtualHost> virtualHosts,
 long httpMaxStreamDurationNano,
 @Nullable
 List<Filter.NamedFilterConfig> filterConfigs)

cleanUpRoutes

private void cleanUpRoutes(String error)

cleanUpRouteDiscoveryState

private void cleanUpRouteDiscoveryState()