Class XdsListenerResource

java.lang.Object

io.grpc.xds.client.XdsResourceType<XdsListenerResource.LdsUpdate>

io.grpc.xds.XdsListenerResource

class XdsListenerResource
extends XdsResourceType<XdsListenerResource.LdsUpdate>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	XdsListenerResource.LdsUpdate

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_LDS
private static final FilterRegistry	filterRegistry
private static final XdsListenerResource	instance
private static final String	TRANSPORT_SOCKET_NAME_TLS
(package private) static final String	TYPE_URL_HTTP_CONNECTION_MANAGER

Fields inherited from class XdsResourceType

HASH_POLICY_FILTER_STATE_KEY, TYPE_URL_CLUSTER_CONFIG, TYPE_URL_TYPED_STRUCT, TYPE_URL_TYPED_STRUCT_UDPA

Constructor Summary

Constructors

Constructor	Description
XdsListenerResource()

Method Summary

Modifier and Type	Method	Description
private static void	checkForUniqueness(Set<EnvoyServerProtoData.FilterChainMatch> uniqueSet, EnvoyServerProtoData.FilterChainMatch filterChainMatch)
protected XdsListenerResource.LdsUpdate	doParse(XdsResourceType.Args args, com.google.protobuf.Message unpackedMessage)
private static List<EnvoyServerProtoData.FilterChainMatch>	expandOnApplicationProtocols(Collection<EnvoyServerProtoData.FilterChainMatch> set)
private static List<EnvoyServerProtoData.FilterChainMatch>	expandOnPrefixRange(EnvoyServerProtoData.FilterChainMatch filterChainMatch)
private static List<EnvoyServerProtoData.FilterChainMatch>	expandOnServerNames(Collection<EnvoyServerProtoData.FilterChainMatch> set)
private static List<EnvoyServerProtoData.FilterChainMatch>	expandOnSourcePorts(Collection<EnvoyServerProtoData.FilterChainMatch> set)
private static List<EnvoyServerProtoData.FilterChainMatch>	expandOnSourcePrefixRange(Collection<EnvoyServerProtoData.FilterChainMatch> set)
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 List<EnvoyServerProtoData.FilterChainMatch>	getCrossProduct(EnvoyServerProtoData.FilterChainMatch filterChainMatch)
(package private) static XdsListenerResource	getInstance()
protected boolean	isFullStateOfTheWorld()
private static boolean	isTerminalFilter(Filter.FilterConfig filterConfig)
(package private) static EnvoyServerProtoData.FilterChain	parseFilterChain(FilterChain proto, TlsContextManager tlsContextManager, FilterRegistry filterRegistry, Set<EnvoyServerProtoData.FilterChainMatch> uniqueSet, Set<String> certProviderInstances)
private static EnvoyServerProtoData.FilterChainMatch	parseFilterChainMatch(FilterChainMatch proto)
(package private) static HttpConnectionManager	parseHttpConnectionManager(HttpConnectionManager proto, FilterRegistry filterRegistry, boolean isForClient)
(package private) static XdsResourceType.StructOrError<Filter.FilterConfig>	parseHttpFilter(HttpFilter httpFilter, FilterRegistry filterRegistry, boolean isForClient)
(package private) static EnvoyServerProtoData.Listener	parseServerSideListener(Listener proto, TlsContextManager tlsContextManager, FilterRegistry filterRegistry, Set<String> certProviderInstances)
private XdsListenerResource.LdsUpdate	processClientSideListener(Listener listener)
private XdsListenerResource.LdsUpdate	processServerSideListener(Listener proto, XdsResourceType.Args args)
boolean	shouldRetrieveResourceKeysForArgs()
String	typeName()
String	typeUrl()
protected Class<Listener>	unpackedClassName()
(package private) static DownstreamTlsContext	validateDownstreamTlsContext(DownstreamTlsContext downstreamTlsContext, Set<String> certProviderInstances)

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_LDS

static final String ADS_TYPE_URL_LDS

See Also:

• Constant Field Values

TYPE_URL_HTTP_CONNECTION_MANAGER

static final String TYPE_URL_HTTP_CONNECTION_MANAGER

See Also:

• Constant Field Values

TRANSPORT_SOCKET_NAME_TLS

private static final String TRANSPORT_SOCKET_NAME_TLS

See Also:

• Constant Field Values

instance

private static final XdsListenerResource instance

filterRegistry

private static final FilterRegistry filterRegistry

Constructor Details

XdsListenerResource

XdsListenerResource()

Method Details

getInstance

static XdsListenerResource 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<XdsListenerResource.LdsUpdate>

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<XdsListenerResource.LdsUpdate>

unpackedClassName

protected Class<Listener> unpackedClassName()

Specified by:

unpackedClassName in class XdsResourceType<XdsListenerResource.LdsUpdate>

typeUrl

public String typeUrl()

Specified by:

typeUrl in class XdsResourceType<XdsListenerResource.LdsUpdate>

shouldRetrieveResourceKeysForArgs

public boolean shouldRetrieveResourceKeysForArgs()

Specified by:

shouldRetrieveResourceKeysForArgs in class XdsResourceType<XdsListenerResource.LdsUpdate>

isFullStateOfTheWorld

protected boolean isFullStateOfTheWorld()

Specified by:

isFullStateOfTheWorld in class XdsResourceType<XdsListenerResource.LdsUpdate>

doParse

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

Specified by:

doParse in class XdsResourceType<XdsListenerResource.LdsUpdate>

Throws:

XdsResourceType.ResourceInvalidException

processClientSideListener

private XdsListenerResource.LdsUpdate processClientSideListener(Listener listener)
                                                         throws XdsResourceType.ResourceInvalidException

Throws:

XdsResourceType.ResourceInvalidException

processServerSideListener

private XdsListenerResource.LdsUpdate processServerSideListener(Listener proto,
 XdsResourceType.Args args)
                                                         throws XdsResourceType.ResourceInvalidException

Throws:

XdsResourceType.ResourceInvalidException

parseServerSideListener

static EnvoyServerProtoData.Listener parseServerSideListener(Listener proto,
 TlsContextManager tlsContextManager,
 FilterRegistry filterRegistry,
 Set<String> certProviderInstances)
                                                      throws XdsResourceType.ResourceInvalidException

Throws:

XdsResourceType.ResourceInvalidException

parseFilterChain

static EnvoyServerProtoData.FilterChain parseFilterChain(FilterChain proto,
 TlsContextManager tlsContextManager,
 FilterRegistry filterRegistry,
 Set<EnvoyServerProtoData.FilterChainMatch> uniqueSet,
 Set<String> certProviderInstances)
                                                  throws XdsResourceType.ResourceInvalidException

Throws:

XdsResourceType.ResourceInvalidException

validateDownstreamTlsContext

static DownstreamTlsContext validateDownstreamTlsContext(DownstreamTlsContext downstreamTlsContext,
 Set<String> certProviderInstances)
                                                  throws XdsResourceType.ResourceInvalidException

Throws:

XdsResourceType.ResourceInvalidException

checkForUniqueness

private static void checkForUniqueness(Set<EnvoyServerProtoData.FilterChainMatch> uniqueSet,
 EnvoyServerProtoData.FilterChainMatch filterChainMatch)
                                throws XdsResourceType.ResourceInvalidException

Throws:

XdsResourceType.ResourceInvalidException

getCrossProduct

private static List<EnvoyServerProtoData.FilterChainMatch> getCrossProduct(EnvoyServerProtoData.FilterChainMatch filterChainMatch)

expandOnPrefixRange

private static List<EnvoyServerProtoData.FilterChainMatch> expandOnPrefixRange(EnvoyServerProtoData.FilterChainMatch filterChainMatch)

expandOnApplicationProtocols

private static List<EnvoyServerProtoData.FilterChainMatch> expandOnApplicationProtocols(Collection<EnvoyServerProtoData.FilterChainMatch> set)

expandOnSourcePrefixRange

private static List<EnvoyServerProtoData.FilterChainMatch> expandOnSourcePrefixRange(Collection<EnvoyServerProtoData.FilterChainMatch> set)

expandOnSourcePorts

private static List<EnvoyServerProtoData.FilterChainMatch> expandOnSourcePorts(Collection<EnvoyServerProtoData.FilterChainMatch> set)

expandOnServerNames

private static List<EnvoyServerProtoData.FilterChainMatch> expandOnServerNames(Collection<EnvoyServerProtoData.FilterChainMatch> set)

parseFilterChainMatch

private static EnvoyServerProtoData.FilterChainMatch parseFilterChainMatch(FilterChainMatch proto)
                                                                    throws XdsResourceType.ResourceInvalidException

Throws:

XdsResourceType.ResourceInvalidException

parseHttpConnectionManager

static HttpConnectionManager parseHttpConnectionManager(HttpConnectionManager proto,
 FilterRegistry filterRegistry,
 boolean isForClient)
                                                 throws XdsResourceType.ResourceInvalidException

Throws:

XdsResourceType.ResourceInvalidException

isTerminalFilter

private static boolean isTerminalFilter(Filter.FilterConfig filterConfig)

parseHttpFilter

@Nullable
static XdsResourceType.StructOrError<Filter.FilterConfig> parseHttpFilter(HttpFilter httpFilter,
 FilterRegistry filterRegistry,
 boolean isForClient)