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 final LoadBalancer.Helper	delegate
(package private) final HashSet<HealthCheckingLoadBalancerFactory.HealthCheckState>	hcStates
(package private) String	healthCheckedService
private final SynchronizationContext	syncContext

Constructor Summary

Constructors

Constructor	Description
HelperImpl(LoadBalancer.Helper delegate)

Method Summary

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(String service)
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

Methods inherited from class java.lang.Object

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

Field Details

delegate

private final LoadBalancer.Helper delegate

syncContext

private final SynchronizationContext syncContext

healthCheckedService

@Nullable
String healthCheckedService

hcStates

final HashSet<HealthCheckingLoadBalancerFactory.HealthCheckState> hcStates

Constructor Details

HelperImpl

HelperImpl(LoadBalancer.Helper delegate)

Method Details

delegate

protected LoadBalancer.Helper delegate()

Description copied from class: ForwardingLoadBalancerHelper

Returns the underlying helper.

Specified by:

delegate in class ForwardingLoadBalancerHelper

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. The attrs are custom attributes associated with this Subchannel, and can be accessed later through Subchannel.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 class ForwardingLoadBalancerHelper

Returns:

Must return a valid Subchannel object, may not return null.

setHealthCheckedService

void setHealthCheckedService(@Nullable
 String service)

toString

public String toString()

Overrides:

toString in class ForwardingLoadBalancerHelper