Package io.grpc.xds

Class XdsServerWrapper.DiscoveryState.RouteDiscoveryState

java.lang.Object

io.grpc.xds.XdsServerWrapper.DiscoveryState.RouteDiscoveryState

All Implemented Interfaces:

XdsClient.ResourceWatcher<XdsRouteConfigureResource.RdsUpdate>

Enclosing class:

XdsServerWrapper.DiscoveryState

private final class XdsServerWrapper.DiscoveryState.RouteDiscoveryState
extends java.lang.Object
implements XdsClient.ResourceWatcher<XdsRouteConfigureResource.RdsUpdate>

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	isPending
private java.lang.String	resourceName
private com.google.common.collect.ImmutableList<VirtualHost>	savedVirtualHosts

Constructor Summary

Constructors

Modifier	Constructor	Description
private	RouteDiscoveryState(java.lang.String resourceName)

Method Summary

Modifier and Type	Method	Description
private void	maybeUpdateSelector()
void	onChanged(XdsRouteConfigureResource.RdsUpdate 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	updateRdsRoutingConfig()

Methods inherited from class java.lang.Object

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

Field Detail

resourceName

private final java.lang.String resourceName

savedVirtualHosts

private com.google.common.collect.ImmutableList<VirtualHost> savedVirtualHosts

isPending

private boolean isPending

Constructor Detail

RouteDiscoveryState

private RouteDiscoveryState(java.lang.String resourceName)

Method Detail

onChanged

public void onChanged(XdsRouteConfigureResource.RdsUpdate update)

Specified by:

onChanged in interface XdsClient.ResourceWatcher<XdsRouteConfigureResource.RdsUpdate>

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<XdsRouteConfigureResource.RdsUpdate>

Parameters:

resourceName - name of the resource requested in discovery request.

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<XdsRouteConfigureResource.RdsUpdate>

updateRdsRoutingConfig

private void updateRdsRoutingConfig()

maybeUpdateSelector

private void maybeUpdateSelector()