Class XdsEndpointResource

java.lang.Object

io.grpc.xds.client.XdsResourceType<XdsEndpointResource.EdsUpdate>

io.grpc.xds.XdsEndpointResource

class XdsEndpointResource
extends XdsResourceType<XdsEndpointResource.EdsUpdate>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	XdsEndpointResource.EdsUpdate

Nested classes/interfaces inherited from class XdsResourceType

XdsResourceType.Args, XdsResourceType.ResourceInvalidException, XdsResourceType.StructOrError<T>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final String	ADS_TYPE_URL_EDS
static final String	GRPC_EXPERIMENTAL_XDS_DUALSTACK_ENDPOINTS
private static final XdsEndpointResource	instance

Fields inherited from class XdsResourceType

HASH_POLICY_FILTER_STATE_KEY, TRANSPORT_SOCKET_NAME_TLS, TYPE_URL_CLUSTER_CONFIG, TYPE_URL_TYPED_STRUCT, TYPE_URL_TYPED_STRUCT_UDPA

Constructor Summary

Constructors

Constructor	Description
XdsEndpointResource()

Method Summary

Modifier and Type	Method	Description
protected XdsEndpointResource.EdsUpdate	doParse(XdsResourceType.Args args, com.google.protobuf.Message unpackedMessage)
protected String	extractResourceName(com.google.protobuf.Message unpackedResource)	Extract the resource name from an older resource type that included the name within the resource contents itself.
private static InetSocketAddress	getInetSocketAddress(Address address)
(package private) static XdsEndpointResource	getInstance()
private static int	getRatePerMillion(FractionalPercent percent)
private static boolean	isEnabledXdsDualStack()
protected boolean	isFullStateOfTheWorld()
private static Endpoints.DropOverload	parseDropOverload(ClusterLoadAssignment.Policy.DropOverload proto)
private static Locality	parseLocality(Locality proto)
(package private) static XdsResourceType.StructOrError<Endpoints.LocalityLbEndpoints>	parseLocalityLbEndpoints(LocalityLbEndpoints proto)
private static XdsEndpointResource.EdsUpdate	processClusterLoadAssignment(ClusterLoadAssignment assignment)
boolean	shouldRetrieveResourceKeysForArgs()
String	typeName()
String	typeUrl()
protected Class<ClusterLoadAssignment>	unpackedClassName()

Methods inherited from class XdsResourceType

unpackCompatibleType

Methods inherited from class Object

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

Field Details

ADS_TYPE_URL_EDS

static final String ADS_TYPE_URL_EDS

See Also:

• Constant Field Values

GRPC_EXPERIMENTAL_XDS_DUALSTACK_ENDPOINTS

public static final String GRPC_EXPERIMENTAL_XDS_DUALSTACK_ENDPOINTS

See Also:

• Constant Field Values

instance

private static final XdsEndpointResource instance

Constructor Details

XdsEndpointResource

XdsEndpointResource()

Method Details

getInstance

static XdsEndpointResource getInstance()

extractResourceName

@Nullable
protected String extractResourceName(com.google.protobuf.Message unpackedResource)

Description copied from class: XdsResourceType

Extract the resource name from an older resource type that included the name within the resource contents itself. The newer approach has resources wrapped with envoy.service.discovery.v3.Resource which then provides the name. This method is only called for the old approach.

Overrides:

extractResourceName in class XdsResourceType<XdsEndpointResource.EdsUpdate>

Returns:

the resource's name, or null if name is not stored within the resource contents

typeName

public String typeName()

Specified by:

typeName in class XdsResourceType<XdsEndpointResource.EdsUpdate>

typeUrl

public String typeUrl()

Specified by:

typeUrl in class XdsResourceType<XdsEndpointResource.EdsUpdate>

shouldRetrieveResourceKeysForArgs

public boolean shouldRetrieveResourceKeysForArgs()

Specified by:

shouldRetrieveResourceKeysForArgs in class XdsResourceType<XdsEndpointResource.EdsUpdate>

isFullStateOfTheWorld

protected boolean isFullStateOfTheWorld()

Specified by:

isFullStateOfTheWorld in class XdsResourceType<XdsEndpointResource.EdsUpdate>

unpackedClassName

protected Class<ClusterLoadAssignment> unpackedClassName()

Specified by:

unpackedClassName in class XdsResourceType<XdsEndpointResource.EdsUpdate>

doParse

protected XdsEndpointResource.EdsUpdate doParse(XdsResourceType.Args args,
 com.google.protobuf.Message unpackedMessage)
                                         throws XdsResourceType.ResourceInvalidException

Specified by:

doParse in class XdsResourceType<XdsEndpointResource.EdsUpdate>

Throws:

XdsResourceType.ResourceInvalidException

isEnabledXdsDualStack

private static boolean isEnabledXdsDualStack()

processClusterLoadAssignment

private static XdsEndpointResource.EdsUpdate processClusterLoadAssignment(ClusterLoadAssignment assignment)
                                                                   throws XdsResourceType.ResourceInvalidException

Throws:

XdsResourceType.ResourceInvalidException

parseLocality

private static Locality parseLocality(Locality proto)

parseDropOverload

private static Endpoints.DropOverload parseDropOverload(ClusterLoadAssignment.Policy.DropOverload proto)

getRatePerMillion

private static int getRatePerMillion(FractionalPercent percent)

parseLocalityLbEndpoints

@Nullable
static XdsResourceType.StructOrError<Endpoints.LocalityLbEndpoints> parseLocalityLbEndpoints(LocalityLbEndpoints proto)

getInetSocketAddress

private static InetSocketAddress getInetSocketAddress(Address address)