Package io.grpc.xds

Class ClusterImplLoadBalancer.ClusterImplLbHelper.RequestLimitingSubchannelPicker

java.lang.Object
io.grpc.LoadBalancer.SubchannelPicker
io.grpc.xds.ClusterImplLoadBalancer.ClusterImplLbHelper.RequestLimitingSubchannelPicker
Enclosing class:
ClusterImplLoadBalancer.ClusterImplLbHelper

private class ClusterImplLoadBalancer.ClusterImplLbHelper.RequestLimitingSubchannelPicker extends io.grpc.LoadBalancer.SubchannelPicker
  • Field Details

    • delegate

      private final io.grpc.LoadBalancer.SubchannelPicker delegate
    • dropPolicies

      private final List<Endpoints.DropOverload> dropPolicies
    • maxConcurrentRequests

      private final long maxConcurrentRequests
    • filterMetadata

      private final Map<String,com.google.protobuf.Struct> filterMetadata
  • Constructor Details

    • RequestLimitingSubchannelPicker

      private RequestLimitingSubchannelPicker(io.grpc.LoadBalancer.SubchannelPicker delegate, List<Endpoints.DropOverload> dropPolicies, long maxConcurrentRequests, Map<String,com.google.protobuf.Struct> filterMetadata)
  • Method Details

    • pickSubchannel

      public io.grpc.LoadBalancer.PickResult pickSubchannel(io.grpc.LoadBalancer.PickSubchannelArgs args)
      Specified by:
      pickSubchannel in class io.grpc.LoadBalancer.SubchannelPicker
    • toString

      public String toString()
      Overrides:
      toString in class Object