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

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

Methods inherited from class java.lang.Object

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

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 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
                             java.lang.String service)

toString

public java.lang.String toString()

Overrides:

toString in class ForwardingLoadBalancerHelper