Package io.grpc.xds
Class XdsRouteConfigureResource
java.lang.Object
io.grpc.xds.client.XdsResourceType<XdsRouteConfigureResource.RdsUpdate>
io.grpc.xds.XdsRouteConfigureResource
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
Nested classes/interfaces inherited from class io.grpc.xds.client.XdsResourceType
XdsResourceType.Args, XdsResourceType.ResourceInvalidException, XdsResourceType.StructOrError<T>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) static final String
(package private) static boolean
private static final XdsRouteConfigureResource
private static final Set
<io.grpc.Status.Code> private static final String
Fields inherited from class io.grpc.xds.client.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 -
Method Summary
Modifier and TypeMethodDescriptionprotected XdsRouteConfigureResource.RdsUpdate
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.(package private) static List
<VirtualHost> extractVirtualHosts
(RouteConfiguration routeConfig, FilterRegistry filterRegistry) (package private) static XdsRouteConfigureResource
protected boolean
private static ClusterSpecifierPlugin.PluginConfig
parseClusterSpecifierPlugin
(ClusterSpecifierPlugin pluginProto) (package private) static ClusterSpecifierPlugin.PluginConfig
parseClusterSpecifierPlugin
(ClusterSpecifierPlugin pluginProto, ClusterSpecifierPluginRegistry registry) (package private) static XdsResourceType.StructOrError
<VirtualHost.Route.RouteAction.ClusterWeight> parseClusterWeight
(WeightedCluster.ClusterWeight proto, FilterRegistry filterRegistry) private static XdsResourceType.StructOrError
<Matchers.FractionMatcher> (package private) static XdsResourceType.StructOrError
<Matchers.HeaderMatcher> parseHeaderMatcher
(HeaderMatcher proto) (package private) static XdsResourceType.StructOrError
<Map<String, Filter.FilterConfig>> parseOverrideFilterConfigs
(Map<String, com.google.protobuf.Any> rawFilterConfigMap, FilterRegistry filterRegistry) (package private) static XdsResourceType.StructOrError
<VirtualHost.Route.RouteMatch.PathMatcher> parsePathMatcher
(RouteMatch proto) parseRetryPolicy
(RetryPolicy retryPolicyProto) (package private) static XdsResourceType.StructOrError
<VirtualHost.Route> parseRoute
(Route proto, FilterRegistry filterRegistry, Map<String, ClusterSpecifierPlugin.PluginConfig> pluginConfigMap, Set<String> optionalPlugins) (package private) static XdsResourceType.StructOrError
<VirtualHost.Route.RouteAction> parseRouteAction
(RouteAction proto, FilterRegistry filterRegistry, Map<String, ClusterSpecifierPlugin.PluginConfig> pluginConfigMap, Set<String> optionalPlugins) Parses the RouteAction config.(package private) static XdsResourceType.StructOrError
<VirtualHost.Route.RouteMatch> parseRouteMatch
(RouteMatch proto) private static XdsResourceType.StructOrError
<VirtualHost> parseVirtualHost
(VirtualHost proto, FilterRegistry filterRegistry, Map<String, ClusterSpecifierPlugin.PluginConfig> pluginConfigMap, Set<String> optionalPlugins) private static XdsRouteConfigureResource.RdsUpdate
processRouteConfiguration
(RouteConfiguration routeConfig, FilterRegistry filterRegistry) boolean
typeName()
typeUrl()
protected Class
<RouteConfiguration> Methods inherited from class io.grpc.xds.client.XdsResourceType
unpackCompatibleType
-
Field Details
-
enableRouteLookup
static boolean enableRouteLookup -
ADS_TYPE_URL_RDS
- See Also:
-
TYPE_URL_FILTER_CONFIG
- See Also:
-
SUPPORTED_RETRYABLE_CODES
-
instance
-
-
Constructor Details
-
XdsRouteConfigureResource
XdsRouteConfigureResource()
-
-
Method Details
-
getInstance
-
extractResourceName
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 withenvoy.service.discovery.v3.Resource
which then provides the name. This method is only called for the old approach.- Overrides:
extractResourceName
in classXdsResourceType<XdsRouteConfigureResource.RdsUpdate>
- Returns:
- the resource's name, or
null
if name is not stored within the resource contents
-
typeName
- Specified by:
typeName
in classXdsResourceType<XdsRouteConfigureResource.RdsUpdate>
-
typeUrl
- Specified by:
typeUrl
in classXdsResourceType<XdsRouteConfigureResource.RdsUpdate>
-
shouldRetrieveResourceKeysForArgs
public boolean shouldRetrieveResourceKeysForArgs()- Specified by:
shouldRetrieveResourceKeysForArgs
in classXdsResourceType<XdsRouteConfigureResource.RdsUpdate>
-
isFullStateOfTheWorld
protected boolean isFullStateOfTheWorld()- Specified by:
isFullStateOfTheWorld
in classXdsResourceType<XdsRouteConfigureResource.RdsUpdate>
-
unpackedClassName
- Specified by:
unpackedClassName
in classXdsResourceType<XdsRouteConfigureResource.RdsUpdate>
-
doParse
protected XdsRouteConfigureResource.RdsUpdate doParse(XdsResourceType.Args args, com.google.protobuf.Message unpackedMessage) throws XdsResourceType.ResourceInvalidException - Specified by:
doParse
in classXdsResourceType<XdsRouteConfigureResource.RdsUpdate>
- Throws:
XdsResourceType.ResourceInvalidException
-
processRouteConfiguration
private static XdsRouteConfigureResource.RdsUpdate processRouteConfiguration(RouteConfiguration routeConfig, FilterRegistry filterRegistry) throws XdsResourceType.ResourceInvalidException -
extractVirtualHosts
static List<VirtualHost> extractVirtualHosts(RouteConfiguration routeConfig, FilterRegistry filterRegistry) throws XdsResourceType.ResourceInvalidException -
parseVirtualHost
private static XdsResourceType.StructOrError<VirtualHost> parseVirtualHost(VirtualHost proto, FilterRegistry filterRegistry, Map<String, ClusterSpecifierPlugin.PluginConfig> pluginConfigMap, Set<String> optionalPlugins) -
parseOverrideFilterConfigs
static XdsResourceType.StructOrError<Map<String,Filter.FilterConfig>> parseOverrideFilterConfigs(Map<String, com.google.protobuf.Any> rawFilterConfigMap, FilterRegistry filterRegistry) -
parseRoute
@Nullable static XdsResourceType.StructOrError<VirtualHost.Route> parseRoute(Route proto, FilterRegistry filterRegistry, Map<String, ClusterSpecifierPlugin.PluginConfig> pluginConfigMap, Set<String> optionalPlugins) -
parseRouteMatch
@Nullable static XdsResourceType.StructOrError<VirtualHost.Route.RouteMatch> parseRouteMatch(RouteMatch proto) -
parsePathMatcher
static XdsResourceType.StructOrError<VirtualHost.Route.RouteMatch.PathMatcher> parsePathMatcher(RouteMatch proto) -
parseFractionMatcher
private static XdsResourceType.StructOrError<Matchers.FractionMatcher> parseFractionMatcher(FractionalPercent proto) -
parseHeaderMatcher
static XdsResourceType.StructOrError<Matchers.HeaderMatcher> parseHeaderMatcher(HeaderMatcher proto) -
parseRouteAction
@Nullable static XdsResourceType.StructOrError<VirtualHost.Route.RouteAction> parseRouteAction(RouteAction proto, FilterRegistry filterRegistry, Map<String, ClusterSpecifierPlugin.PluginConfig> pluginConfigMap, Set<String> optionalPlugins) Parses the RouteAction config. The returned result may contain a (parsed form)VirtualHost.Route.RouteAction
or an error message. Returnsnull
if the RouteAction should be ignored. -
parseRetryPolicy
@Nullable private static XdsResourceType.StructOrError<VirtualHost.Route.RouteAction.RetryPolicy> parseRetryPolicy(RetryPolicy retryPolicyProto) -
parseClusterWeight
static XdsResourceType.StructOrError<VirtualHost.Route.RouteAction.ClusterWeight> parseClusterWeight(WeightedCluster.ClusterWeight proto, FilterRegistry filterRegistry) -
parseClusterSpecifierPlugin
@Nullable private static ClusterSpecifierPlugin.PluginConfig parseClusterSpecifierPlugin(ClusterSpecifierPlugin pluginProto) throws XdsResourceType.ResourceInvalidException -
parseClusterSpecifierPlugin
@Nullable static ClusterSpecifierPlugin.PluginConfig parseClusterSpecifierPlugin(ClusterSpecifierPlugin pluginProto, ClusterSpecifierPluginRegistry registry) throws XdsResourceType.ResourceInvalidException
-