Class XdsServerWrapper.DiscoveryState

java.lang.Object

io.grpc.xds.XdsServerWrapper.DiscoveryState

All Implemented Interfaces:

XdsClient.ResourceWatcher<XdsListenerResource.LdsUpdate>

Enclosing class:

XdsServerWrapper

private final class XdsServerWrapper.DiscoveryState
extends Object
implements XdsClient.ResourceWatcher<XdsListenerResource.LdsUpdate>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	XdsServerWrapper.DiscoveryState.RouteDiscoveryState

Field Summary

Fields

Modifier and Type	Field	Description
private EnvoyServerProtoData.FilterChain	defaultFilterChain
private List<EnvoyServerProtoData.FilterChain>	filterChains
private final io.grpc.ServerInterceptor	noopInterceptor
private final Set<String>	pendingRds
private final String	resourceName
private final Map<String, XdsServerWrapper.DiscoveryState.RouteDiscoveryState>	routeDiscoveryStates
private final Map<EnvoyServerProtoData.FilterChain, AtomicReference<XdsServerWrapper.ServerRoutingConfig>>	savedRdsRoutingConfigRef
private boolean	stopped

Constructor Summary

Constructors

Modifier	Constructor	Description
private	DiscoveryState(String resourceName)

Method Summary

Modifier and Type	Method	Description
private void	cleanUpRouteDiscoveryStates()
private io.grpc.ServerInterceptor	combineInterceptors(List<io.grpc.ServerInterceptor> interceptors)
private com.google.common.collect.ImmutableMap<VirtualHost.Route, io.grpc.ServerInterceptor>	generatePerRouteInterceptors(List<Filter.NamedFilterConfig> namedFilterConfigs, List<VirtualHost> virtualHosts)
private AtomicReference<XdsServerWrapper.ServerRoutingConfig>	generateRoutingConfig(EnvoyServerProtoData.FilterChain filterChain)
private List<SslContextProviderSupplier>	getSuppliersInUse()
private void	handleConfigNotFound(io.grpc.StatusException exception)
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	releaseSuppliersInFlight()
private void	shutdown()
private void	updateSelector()

Methods inherited from class Object

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

Field Details

resourceName

private final String resourceName

routeDiscoveryStates

private final Map<String, XdsServerWrapper.DiscoveryState.RouteDiscoveryState> routeDiscoveryStates

pendingRds

private final Set<String> pendingRds

filterChains

private List<EnvoyServerProtoData.FilterChain> filterChains

defaultFilterChain

@Nullable
private EnvoyServerProtoData.FilterChain defaultFilterChain

stopped

private boolean stopped

savedRdsRoutingConfigRef

private final Map<EnvoyServerProtoData.FilterChain, AtomicReference<XdsServerWrapper.ServerRoutingConfig>> savedRdsRoutingConfigRef

noopInterceptor

private final io.grpc.ServerInterceptor noopInterceptor

Constructor Details

DiscoveryState

private DiscoveryState(String resourceName)

Method Details

onChanged

public void onChanged(XdsListenerResource.LdsUpdate update)

Specified by:

onChanged 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.

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>

shutdown

private void shutdown()

updateSelector

private void updateSelector()

generateRoutingConfig

private AtomicReference<XdsServerWrapper.ServerRoutingConfig> generateRoutingConfig(EnvoyServerProtoData.FilterChain filterChain)

generatePerRouteInterceptors

private com.google.common.collect.ImmutableMap<VirtualHost.Route, io.grpc.ServerInterceptor> generatePerRouteInterceptors(List<Filter.NamedFilterConfig> namedFilterConfigs,
 List<VirtualHost> virtualHosts)

combineInterceptors

private io.grpc.ServerInterceptor combineInterceptors(List<io.grpc.ServerInterceptor> interceptors)

handleConfigNotFound

private void handleConfigNotFound(io.grpc.StatusException exception)

cleanUpRouteDiscoveryStates

private void cleanUpRouteDiscoveryStates()

getSuppliersInUse

private List<SslContextProviderSupplier> getSuppliersInUse()

releaseSuppliersInFlight

private void releaseSuppliersInFlight()