Package io.grpc.xds
Class ClusterImplLoadBalancer.ClusterImplLbHelper
- java.lang.Object
-
- io.grpc.LoadBalancer.Helper
-
- io.grpc.util.ForwardingLoadBalancerHelper
-
- io.grpc.xds.ClusterImplLoadBalancer.ClusterImplLbHelper
-
- Enclosing class:
- ClusterImplLoadBalancer
private final class ClusterImplLoadBalancer.ClusterImplLbHelper extends io.grpc.util.ForwardingLoadBalancerHelper
A decoratedLoadBalancer.Helper
that applies configurations for connections or requests to endpoints in the cluster.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private class
ClusterImplLoadBalancer.ClusterImplLbHelper.RequestLimitingSubchannelPicker
-
Field Summary
Fields Modifier and Type Field Description private io.grpc.LoadBalancer.SubchannelPicker
currentPicker
private io.grpc.ConnectivityState
currentState
private java.util.List<Endpoints.DropOverload>
dropPolicies
private java.util.Map<java.lang.String,com.google.protobuf.Struct>
filterMetadata
private java.util.concurrent.atomic.AtomicLong
inFlights
private Bootstrapper.ServerInfo
lrsServerInfo
private long
maxConcurrentRequests
private SslContextProviderSupplier
sslContextProviderSupplier
-
Constructor Summary
Constructors Modifier Constructor Description private
ClusterImplLbHelper(java.util.concurrent.atomic.AtomicLong inFlights, Bootstrapper.ServerInfo lrsServerInfo)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private ClusterImplLoadBalancer.ClusterLocality
createClusterLocalityFromAttributes(io.grpc.Attributes addressAttributes)
io.grpc.LoadBalancer.Subchannel
createSubchannel(io.grpc.LoadBalancer.CreateSubchannelArgs args)
protected io.grpc.LoadBalancer.Helper
delegate()
void
updateBalancingState(io.grpc.ConnectivityState newState, io.grpc.LoadBalancer.SubchannelPicker newPicker)
private void
updateDropPolicies(java.util.List<Endpoints.DropOverload> dropOverloads)
private void
updateFilterMetadata(java.util.Map<java.lang.String,com.google.protobuf.Struct> filterMetadata)
private void
updateMaxConcurrentRequests(java.lang.Long maxConcurrentRequests)
private void
updateSslContextProviderSupplier(EnvoyServerProtoData.UpstreamTlsContext tlsContext)
private java.util.List<io.grpc.EquivalentAddressGroup>
withAdditionalAttributes(java.util.List<io.grpc.EquivalentAddressGroup> addresses)
-
Methods inherited from class io.grpc.util.ForwardingLoadBalancerHelper
createOobChannel, createOobChannel, createResolvingOobChannel, createResolvingOobChannelBuilder, createResolvingOobChannelBuilder, getAuthority, getChannelCredentials, getChannelLogger, getChannelTarget, getMetricRecorder, getNameResolverArgs, getNameResolverRegistry, getScheduledExecutorService, getSynchronizationContext, getUnsafeChannelCredentials, ignoreRefreshNameResolutionCheck, refreshNameResolution, toString, updateOobChannelAddresses, updateOobChannelAddresses
-
-
-
-
Field Detail
-
inFlights
private final java.util.concurrent.atomic.AtomicLong inFlights
-
currentState
private io.grpc.ConnectivityState currentState
-
currentPicker
private io.grpc.LoadBalancer.SubchannelPicker currentPicker
-
dropPolicies
private java.util.List<Endpoints.DropOverload> dropPolicies
-
maxConcurrentRequests
private long maxConcurrentRequests
-
sslContextProviderSupplier
@Nullable private SslContextProviderSupplier sslContextProviderSupplier
-
filterMetadata
private java.util.Map<java.lang.String,com.google.protobuf.Struct> filterMetadata
-
lrsServerInfo
@Nullable private final Bootstrapper.ServerInfo lrsServerInfo
-
-
Constructor Detail
-
ClusterImplLbHelper
private ClusterImplLbHelper(java.util.concurrent.atomic.AtomicLong inFlights, @Nullable Bootstrapper.ServerInfo lrsServerInfo)
-
-
Method Detail
-
updateBalancingState
public void updateBalancingState(io.grpc.ConnectivityState newState, io.grpc.LoadBalancer.SubchannelPicker newPicker)
- Overrides:
updateBalancingState
in classio.grpc.util.ForwardingLoadBalancerHelper
-
createSubchannel
public io.grpc.LoadBalancer.Subchannel createSubchannel(io.grpc.LoadBalancer.CreateSubchannelArgs args)
- Overrides:
createSubchannel
in classio.grpc.util.ForwardingLoadBalancerHelper
-
withAdditionalAttributes
private java.util.List<io.grpc.EquivalentAddressGroup> withAdditionalAttributes(java.util.List<io.grpc.EquivalentAddressGroup> addresses)
-
createClusterLocalityFromAttributes
private ClusterImplLoadBalancer.ClusterLocality createClusterLocalityFromAttributes(io.grpc.Attributes addressAttributes)
-
delegate
protected io.grpc.LoadBalancer.Helper delegate()
- Specified by:
delegate
in classio.grpc.util.ForwardingLoadBalancerHelper
-
updateDropPolicies
private void updateDropPolicies(java.util.List<Endpoints.DropOverload> dropOverloads)
-
updateMaxConcurrentRequests
private void updateMaxConcurrentRequests(@Nullable java.lang.Long maxConcurrentRequests)
-
updateSslContextProviderSupplier
private void updateSslContextProviderSupplier(@Nullable EnvoyServerProtoData.UpstreamTlsContext tlsContext)
-
updateFilterMetadata
private void updateFilterMetadata(java.util.Map<java.lang.String,com.google.protobuf.Struct> filterMetadata)
-
-