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 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

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

Methods inherited from class java.lang.Object

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

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 class io.grpc.util.ForwardingLoadBalancerHelper

createSubchannel

public io.grpc.LoadBalancer.Subchannel createSubchannel(io.grpc.LoadBalancer.CreateSubchannelArgs args)

Overrides:

createSubchannel in class io.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 class io.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)