Package io.grpc.xds

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

      • inFlights

        private final java.util.concurrent.atomic.AtomicLong inFlights
      • currentState

        private io.grpc.ConnectivityState currentState
      • currentPicker

        private io.grpc.LoadBalancer.SubchannelPicker currentPicker
      • maxConcurrentRequests

        private long maxConcurrentRequests
      • filterMetadata

        private java.util.Map<java.lang.String,​com.google.protobuf.Struct> filterMetadata
    • 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)
      • 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)
      • updateFilterMetadata

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