Class CdsLoadBalancer2.CdsLbState.ClusterState

java.lang.Object

io.grpc.xds.CdsLoadBalancer2.CdsLbState.ClusterState

All Implemented Interfaces:

XdsClient.ResourceWatcher<XdsClusterResource.CdsUpdate>

Enclosing class:

CdsLoadBalancer2.CdsLbState

private final class CdsLoadBalancer2.CdsLbState.ClusterState
extends Object
implements XdsClient.ResourceWatcher<XdsClusterResource.CdsUpdate>

Field Summary

Fields

Modifier and Type	Field	Description
private Map<String, CdsLoadBalancer2.CdsLbState.ClusterState>	childClusterStates
private boolean	discovered
private boolean	isLeaf
private final String	name
private XdsClusterResource.CdsUpdate	result
private boolean	shutdown

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ClusterState(String name)

Method Summary

Modifier and Type	Method	Description
void	onChanged(XdsClusterResource.CdsUpdate 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.
(package private) void	shutdown()
private void	start()

Methods inherited from class Object

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

Field Details

name

private final String name

childClusterStates

@Nullable
private Map<String, CdsLoadBalancer2.CdsLbState.ClusterState> childClusterStates

result

@Nullable
private XdsClusterResource.CdsUpdate result

isLeaf

private boolean isLeaf

discovered

private boolean discovered

shutdown

private boolean shutdown

Constructor Details

ClusterState

private ClusterState(String name)

Method Details

start

private void start()

shutdown

void shutdown()

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<XdsClusterResource.CdsUpdate>

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<XdsClusterResource.CdsUpdate>

Parameters:

resourceName - name of the resource requested in discovery request.

onChanged

public void onChanged(XdsClusterResource.CdsUpdate update)

Specified by:

onChanged in interface XdsClient.ResourceWatcher<XdsClusterResource.CdsUpdate>