Package io.grpc.xds

Class LoadBalancerConfigFactory.LoadBalancingPolicyConverter

java.lang.Object

io.grpc.xds.LoadBalancerConfigFactory.LoadBalancingPolicyConverter

Enclosing class:

LoadBalancerConfigFactory

static class LoadBalancerConfigFactory.LoadBalancingPolicyConverter
extends java.lang.Object

Responsible for converting from a envoy.config.cluster.v3.LoadBalancingPolicy proto message to a gRPC service config format.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	LoadBalancerConfigFactory.LoadBalancingPolicyConverter.MaxRecursionReachedException

Field Summary

Fields

Modifier and Type	Field	Description
private static int	MAX_RECURSION

Constructor Summary

Constructors

Constructor	Description
LoadBalancingPolicyConverter()

Method Summary

Modifier and Type	Method	Description
private static com.google.common.collect.ImmutableMap<java.lang.String,?>	convertCustomConfig(TypedStruct configTypedStruct)	Converts a custom UDPA (legacy) TypedStruct LB config to service config format.
private static com.google.common.collect.ImmutableMap<java.lang.String,?>	convertCustomConfig(TypedStruct configTypedStruct)	Converts a custom TypedStruct LB config to service config format.
private static com.google.common.collect.ImmutableMap<java.lang.String,?>	convertLeastRequestConfig(LeastRequest leastRequest)	Converts a least_request Any configuration to service config format.
private static com.google.common.collect.ImmutableMap<java.lang.String,?>	convertPickFirstConfig(PickFirst pickFirst)	"Converts" a pick_first configuration to service config format.
private static com.google.common.collect.ImmutableMap<java.lang.String,?>	convertRingHashConfig(RingHash ringHash)	Converts a ring_hash Any configuration to service config format.
private static com.google.common.collect.ImmutableMap<java.lang.String,?>	convertRoundRobinConfig()	"Converts" a round_robin configuration to service config format.
private static com.google.common.collect.ImmutableMap<java.lang.String,?>	convertToServiceConfig(LoadBalancingPolicy loadBalancingPolicy, int recursionDepth)	Converts a LoadBalancingPolicy object to a service config JSON object.
private static com.google.common.collect.ImmutableMap<java.lang.String,?>	convertWeightedRoundRobinConfig(ClientSideWeightedRoundRobin wrr)
private static com.google.common.collect.ImmutableMap<java.lang.String,?>	convertWrrLocalityConfig(WrrLocality wrrLocality, int recursionDepth)	Converts a wrr_locality Any configuration to service config format.
private static java.lang.Object	parseCustomConfigJson(com.google.protobuf.Struct configStruct)	Print the config Struct into JSON and then parse that into our internal representation.
private static java.lang.String	parseCustomConfigTypeName(java.lang.String customConfigTypeName)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_RECURSION

private static final int MAX_RECURSION

See Also:

Constant Field Values

Constructor Detail

LoadBalancingPolicyConverter

LoadBalancingPolicyConverter()

Method Detail

convertToServiceConfig

private static com.google.common.collect.ImmutableMap<java.lang.String,?> convertToServiceConfig(LoadBalancingPolicy loadBalancingPolicy,
                                                                                                       int recursionDepth)
                                                                                                throws XdsResourceType.ResourceInvalidException,
                                                                                                       LoadBalancerConfigFactory.LoadBalancingPolicyConverter.MaxRecursionReachedException

Converts a LoadBalancingPolicy object to a service config JSON object.

Throws:

XdsResourceType.ResourceInvalidException

LoadBalancerConfigFactory.LoadBalancingPolicyConverter.MaxRecursionReachedException

convertRingHashConfig

private static com.google.common.collect.ImmutableMap<java.lang.String,?> convertRingHashConfig(RingHash ringHash)
                                                                                               throws XdsResourceType.ResourceInvalidException

Converts a ring_hash Any configuration to service config format.

Throws:

XdsResourceType.ResourceInvalidException

convertWeightedRoundRobinConfig

private static com.google.common.collect.ImmutableMap<java.lang.String,?> convertWeightedRoundRobinConfig(ClientSideWeightedRoundRobin wrr)
                                                                                                         throws XdsResourceType.ResourceInvalidException

Throws:

XdsResourceType.ResourceInvalidException

convertWrrLocalityConfig

private static com.google.common.collect.ImmutableMap<java.lang.String,?> convertWrrLocalityConfig(WrrLocality wrrLocality,
                                                                                                         int recursionDepth)
                                                                                                  throws XdsResourceType.ResourceInvalidException,
                                                                                                         LoadBalancerConfigFactory.LoadBalancingPolicyConverter.MaxRecursionReachedException

Converts a wrr_locality Any configuration to service config format.

Throws:

XdsResourceType.ResourceInvalidException

LoadBalancerConfigFactory.LoadBalancingPolicyConverter.MaxRecursionReachedException

convertRoundRobinConfig

private static com.google.common.collect.ImmutableMap<java.lang.String,?> convertRoundRobinConfig()

"Converts" a round_robin configuration to service config format.

convertPickFirstConfig

private static com.google.common.collect.ImmutableMap<java.lang.String,?> convertPickFirstConfig(PickFirst pickFirst)

"Converts" a pick_first configuration to service config format.

convertLeastRequestConfig

private static com.google.common.collect.ImmutableMap<java.lang.String,?> convertLeastRequestConfig(LeastRequest leastRequest)
                                                                                                   throws XdsResourceType.ResourceInvalidException

Converts a least_request Any configuration to service config format.

Throws:

XdsResourceType.ResourceInvalidException

convertCustomConfig

private static com.google.common.collect.ImmutableMap<java.lang.String,?> convertCustomConfig(TypedStruct configTypedStruct)
                                                                                             throws XdsResourceType.ResourceInvalidException

Converts a custom TypedStruct LB config to service config format.

Throws:

XdsResourceType.ResourceInvalidException

convertCustomConfig

private static com.google.common.collect.ImmutableMap<java.lang.String,?> convertCustomConfig(TypedStruct configTypedStruct)
                                                                                             throws XdsResourceType.ResourceInvalidException

Converts a custom UDPA (legacy) TypedStruct LB config to service config format.

Throws:

XdsResourceType.ResourceInvalidException

parseCustomConfigJson

private static java.lang.Object parseCustomConfigJson(com.google.protobuf.Struct configStruct)
                                               throws XdsResourceType.ResourceInvalidException

Print the config Struct into JSON and then parse that into our internal representation.

Throws:

XdsResourceType.ResourceInvalidException

parseCustomConfigTypeName

private static java.lang.String parseCustomConfigTypeName(java.lang.String customConfigTypeName)