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 decorated
LoadBalancer.Helper
that applies configurations for connections
or requests to endpoints in the cluster.-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate io.grpc.LoadBalancer.SubchannelPicker
private io.grpc.ConnectivityState
private List
<Endpoints.DropOverload> private final AtomicLong
private final Bootstrapper.ServerInfo
private long
private SslContextProviderSupplier
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
ClusterImplLbHelper
(AtomicLong inFlights, Bootstrapper.ServerInfo lrsServerInfo) -
Method Summary
Modifier and TypeMethodDescriptioncreateClusterLocalityFromAttributes
(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
(List<Endpoints.DropOverload> dropOverloads) private void
updateFilterMetadata
(Map<String, com.google.protobuf.Struct> filterMetadata) private void
updateMaxConcurrentRequests
(Long maxConcurrentRequests) private void
private List
<io.grpc.EquivalentAddressGroup> withAdditionalAttributes
(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 Details
-
inFlights
-
currentState
private io.grpc.ConnectivityState currentState -
currentPicker
private io.grpc.LoadBalancer.SubchannelPicker currentPicker -
dropPolicies
-
maxConcurrentRequests
private long maxConcurrentRequests -
sslContextProviderSupplier
-
filterMetadata
-
lrsServerInfo
-
-
Constructor Details
-
ClusterImplLbHelper
-
-
Method Details
-
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
-
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
-
updateMaxConcurrentRequests
-
updateSslContextProviderSupplier
private void updateSslContextProviderSupplier(@Nullable EnvoyServerProtoData.UpstreamTlsContext tlsContext) -
updateFilterMetadata
-