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)