Class ClusterResolverLoadBalancer.ClusterResolverLbState.EdsClusterState

java.lang.Object

io.grpc.xds.ClusterResolverLoadBalancer.ClusterResolverLbState.ClusterState

io.grpc.xds.ClusterResolverLoadBalancer.ClusterResolverLbState.EdsClusterState

All Implemented Interfaces:

XdsClient.ResourceWatcher<XdsEndpointResource.EdsUpdate>

Enclosing class:

ClusterResolverLoadBalancer.ClusterResolverLbState

private final class ClusterResolverLoadBalancer.ClusterResolverLbState.EdsClusterState
extends ClusterResolverLoadBalancer.ClusterResolverLbState.ClusterState
implements XdsClient.ResourceWatcher<XdsEndpointResource.EdsUpdate>

Field Summary

Fields

Modifier and Type	Field	Description
private final String	edsServiceName
private Map<Locality,String>	localityPriorityNames
(package private) int	priorityNameGenId

Fields inherited from class ClusterResolverLoadBalancer.ClusterResolverLbState.ClusterState

filterMetadata, lrsServerInfo, maxConcurrentRequests, name, outlierDetection, resolved, result, shutdown, status, tlsContext

Constructor Summary

Constructors

Modifier	Constructor	Description
private	EdsClusterState(String name, String edsServiceName, Bootstrapper.ServerInfo lrsServerInfo, Long maxConcurrentRequests, EnvoyServerProtoData.UpstreamTlsContext tlsContext, Map<String, com.google.protobuf.Struct> filterMetadata, EnvoyServerProtoData.OutlierDetection outlierDetection)

Method Summary

Modifier and Type	Method	Description
private List<String>	generatePriorityNames(String name, Map<Locality, Endpoints.LocalityLbEndpoints> localityLbEndpoints)
void	onChanged(XdsEndpointResource.EdsUpdate 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.
protected void	shutdown()
(package private) void	start()

Methods inherited from class Object

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

Field Details

edsServiceName

@Nullable
private final String edsServiceName

localityPriorityNames

private Map<Locality,String> localityPriorityNames

priorityNameGenId

int priorityNameGenId

Constructor Details

EdsClusterState

private EdsClusterState(String name,
 @Nullable
 String edsServiceName,
 @Nullable
 Bootstrapper.ServerInfo lrsServerInfo,
 @Nullable
 Long maxConcurrentRequests,
 @Nullable
 EnvoyServerProtoData.UpstreamTlsContext tlsContext,
 Map<String, com.google.protobuf.Struct> filterMetadata,
 @Nullable
 EnvoyServerProtoData.OutlierDetection outlierDetection)

Method Details

start

void start()

Specified by:

start in class ClusterResolverLoadBalancer.ClusterResolverLbState.ClusterState

shutdown

protected void shutdown()

Overrides:

shutdown in class ClusterResolverLoadBalancer.ClusterResolverLbState.ClusterState

onChanged

public void onChanged(XdsEndpointResource.EdsUpdate update)

Specified by:

onChanged in interface XdsClient.ResourceWatcher<XdsEndpointResource.EdsUpdate>

generatePriorityNames

private List<String> generatePriorityNames(String name,
 Map<Locality, Endpoints.LocalityLbEndpoints> localityLbEndpoints)

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<XdsEndpointResource.EdsUpdate>

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<XdsEndpointResource.EdsUpdate>