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.
  • Field Details

    • inFlights

      private final AtomicLong inFlights
    • currentState

      private io.grpc.ConnectivityState currentState
    • currentPicker

      private io.grpc.LoadBalancer.SubchannelPicker currentPicker
    • dropPolicies

      private List<Endpoints.DropOverload> dropPolicies
    • maxConcurrentRequests

      private long maxConcurrentRequests
    • sslContextProviderSupplier

      @Nullable private SslContextProviderSupplier sslContextProviderSupplier
    • filterMetadata

      private Map<String,com.google.protobuf.Struct> filterMetadata
    • lrsServerInfo

      @Nullable private final Bootstrapper.ServerInfo lrsServerInfo
  • Constructor Details

  • Method Details

    • 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 List<io.grpc.EquivalentAddressGroup> withAdditionalAttributes(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(List<Endpoints.DropOverload> dropOverloads)
    • updateMaxConcurrentRequests

      private void updateMaxConcurrentRequests(@Nullable Long maxConcurrentRequests)
    • updateSslContextProviderSupplier

      private void updateSslContextProviderSupplier(@Nullable EnvoyServerProtoData.UpstreamTlsContext tlsContext)
    • updateFilterMetadata

      private void updateFilterMetadata(Map<String,com.google.protobuf.Struct> filterMetadata)