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 java.lang.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 io.grpc.NameResolver.ConfigOrError	emptyServiceConfig
private java.util.Set<java.lang.String>	existingClusters
private java.lang.String	ldsResourceName
private XdsNameResolver.ResolveState.RouteDiscoveryState	routeDiscoveryState
private boolean	stopped

Constructor Summary

Constructors

Constructor	Description
ResolveState(java.lang.String ldsResourceName)

Method Summary

Modifier and Type	Method	Description
private void	cleanUpRouteDiscoveryState()
private void	cleanUpRoutes(java.lang.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(java.lang.String resourceName)	Called when the requested resource is not available.
private void	start()
private void	stop()
private void	updateRoutes(java.util.List<VirtualHost> virtualHosts, long httpMaxStreamDurationNano, java.util.List<Filter.NamedFilterConfig> filterConfigs)

Methods inherited from class java.lang.Object

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

Field Detail

emptyServiceConfig

private final io.grpc.NameResolver.ConfigOrError emptyServiceConfig

ldsResourceName

private final java.lang.String ldsResourceName

stopped

private boolean stopped

existingClusters

@Nullable
private java.util.Set<java.lang.String> existingClusters

routeDiscoveryState

@Nullable
private XdsNameResolver.ResolveState.RouteDiscoveryState routeDiscoveryState

Constructor Detail

ResolveState

ResolveState(java.lang.String ldsResourceName)

Method Detail

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(java.lang.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(java.util.List<VirtualHost> virtualHosts,
                          long httpMaxStreamDurationNano,
                          @Nullable
                          java.util.List<Filter.NamedFilterConfig> filterConfigs)

cleanUpRoutes

private void cleanUpRoutes(java.lang.String error)

cleanUpRouteDiscoveryState

private void cleanUpRouteDiscoveryState()