Package io.grpc.protobuf.services
Class HealthCheckingLoadBalancerFactory.HelperImpl
- java.lang.Object
-
- io.grpc.LoadBalancer.Helper
-
- io.grpc.util.ForwardingLoadBalancerHelper
-
- io.grpc.protobuf.services.HealthCheckingLoadBalancerFactory.HelperImpl
-
- Enclosing class:
- HealthCheckingLoadBalancerFactory
private final class HealthCheckingLoadBalancerFactory.HelperImpl extends ForwardingLoadBalancerHelper
-
-
Field Summary
Fields Modifier and Type Field Description private LoadBalancer.Helper
delegate
(package private) java.util.HashSet<HealthCheckingLoadBalancerFactory.HealthCheckState>
hcStates
(package private) java.lang.String
healthCheckedService
private SynchronizationContext
syncContext
-
Constructor Summary
Constructors Constructor Description HelperImpl(LoadBalancer.Helper delegate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description LoadBalancer.Subchannel
createSubchannel(LoadBalancer.CreateSubchannelArgs args)
Creates a Subchannel, which is a logical connection to the given group of addresses which are considered equivalent.protected LoadBalancer.Helper
delegate()
Returns the underlying helper.(package private) void
setHealthCheckedService(java.lang.String service)
java.lang.String
toString()
-
Methods inherited from class io.grpc.util.ForwardingLoadBalancerHelper
createOobChannel, createOobChannel, createResolvingOobChannel, createResolvingOobChannelBuilder, createResolvingOobChannelBuilder, getAuthority, getChannelCredentials, getChannelLogger, getChannelTarget, getMetricRecorder, getNameResolverArgs, getNameResolverRegistry, getScheduledExecutorService, getSynchronizationContext, getUnsafeChannelCredentials, ignoreRefreshNameResolutionCheck, refreshNameResolution, updateBalancingState, updateOobChannelAddresses, updateOobChannelAddresses
-
-
-
-
Field Detail
-
delegate
private final LoadBalancer.Helper delegate
-
syncContext
private final SynchronizationContext syncContext
-
healthCheckedService
@Nullable java.lang.String healthCheckedService
-
hcStates
final java.util.HashSet<HealthCheckingLoadBalancerFactory.HealthCheckState> hcStates
-
-
Constructor Detail
-
HelperImpl
HelperImpl(LoadBalancer.Helper delegate)
-
-
Method Detail
-
delegate
protected LoadBalancer.Helper delegate()
Description copied from class:ForwardingLoadBalancerHelper
Returns the underlying helper.- Specified by:
delegate
in classForwardingLoadBalancerHelper
-
createSubchannel
public LoadBalancer.Subchannel createSubchannel(LoadBalancer.CreateSubchannelArgs args)
Description copied from class:LoadBalancer.Helper
Creates a Subchannel, which is a logical connection to the given group of addresses which are considered equivalent. Theattrs
are custom attributes associated with this Subchannel, and can be accessed later throughSubchannel.getAttributes()
.The LoadBalancer is responsible for closing unused Subchannels, and closing all Subchannels within
LoadBalancer.shutdown()
.It must be called from
the Synchronization Context
- Overrides:
createSubchannel
in classForwardingLoadBalancerHelper
- Returns:
- Must return a valid Subchannel object, may not return null.
-
setHealthCheckedService
void setHealthCheckedService(@Nullable java.lang.String service)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classForwardingLoadBalancerHelper
-
-