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 Summary

Fields

Modifier and Type	Field	Description
private io.grpc.LoadBalancer.SubchannelPicker	delegate
private java.util.List<Endpoints.DropOverload>	dropPolicies
private java.util.Map<java.lang.String,com.google.protobuf.Struct>	filterMetadata
private long	maxConcurrentRequests

Constructor Summary

Constructors

Modifier	Constructor	Description
private	RequestLimitingSubchannelPicker(io.grpc.LoadBalancer.SubchannelPicker delegate, java.util.List<Endpoints.DropOverload> dropPolicies, long maxConcurrentRequests, java.util.Map<java.lang.String,com.google.protobuf.Struct> filterMetadata)

Method Summary

Modifier and Type	Method	Description
io.grpc.LoadBalancer.PickResult	pickSubchannel(io.grpc.LoadBalancer.PickSubchannelArgs args)
java.lang.String	toString()

Methods inherited from class io.grpc.LoadBalancer.SubchannelPicker

requestConnection

Methods inherited from class java.lang.Object

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

Field Detail

delegate

private final io.grpc.LoadBalancer.SubchannelPicker delegate

dropPolicies

private final java.util.List<Endpoints.DropOverload> dropPolicies

maxConcurrentRequests

private final long maxConcurrentRequests

filterMetadata

private final java.util.Map<java.lang.String,com.google.protobuf.Struct> filterMetadata

Constructor Detail

RequestLimitingSubchannelPicker

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

Method Detail

pickSubchannel

public io.grpc.LoadBalancer.PickResult pickSubchannel(io.grpc.LoadBalancer.PickSubchannelArgs args)

Specified by:

pickSubchannel in class io.grpc.LoadBalancer.SubchannelPicker

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object