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
All Methods Instance Methods Concrete Methods 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)
-
-
-
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
-
-
Method Detail
-
onChanged
public void onChanged(XdsListenerResource.LdsUpdate update)
- Specified by:
onChanged
in interfaceXdsClient.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
. - KeepStatus
description in one form or another, as it contains valuable debugging information.- Specified by:
onError
in interfaceXdsClient.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 interfaceXdsClient.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()
-
-