@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/5999") @NotThreadSafe public final class GracefulSwitchLoadBalancer extends ForwardingLoadBalancer
The balancer must switch to
a policy prior to handling resolved addresses
for the
first time.
io.grpc.LoadBalancer.CreateSubchannelArgs, io.grpc.LoadBalancer.Factory, io.grpc.LoadBalancer.Helper, io.grpc.LoadBalancer.PickResult, io.grpc.LoadBalancer.PickSubchannelArgs, io.grpc.LoadBalancer.ResolvedAddresses, io.grpc.LoadBalancer.Subchannel, io.grpc.LoadBalancer.SubchannelPicker, io.grpc.LoadBalancer.SubchannelStateListener
Constructor and Description |
---|
GracefulSwitchLoadBalancer(io.grpc.LoadBalancer.Helper helper) |
Modifier and Type | Method and Description |
---|---|
protected io.grpc.LoadBalancer |
delegate()
Returns the underlying balancer.
|
void |
handleSubchannelState(io.grpc.LoadBalancer.Subchannel subchannel,
io.grpc.ConnectivityStateInfo stateInfo)
Deprecated.
|
void |
shutdown() |
void |
switchTo(io.grpc.LoadBalancer.Factory newBalancerFactory)
Gracefully switch to a new policy defined by the given factory, if the given factory isn't
equal to the current one.
|
canHandleEmptyAddressListFromNameResolution, handleNameResolutionError, handleResolvedAddresses, handleResolvedAddressGroups, requestConnection, toString
public GracefulSwitchLoadBalancer(io.grpc.LoadBalancer.Helper helper)
public void switchTo(io.grpc.LoadBalancer.Factory newBalancerFactory)
protected io.grpc.LoadBalancer delegate()
ForwardingLoadBalancer
delegate
in class ForwardingLoadBalancer
@Deprecated public void handleSubchannelState(io.grpc.LoadBalancer.Subchannel subchannel, io.grpc.ConnectivityStateInfo stateInfo)
handleSubchannelState
in class ForwardingLoadBalancer
public void shutdown()
shutdown
in class ForwardingLoadBalancer