Class HealthCheckingLoadBalancerFactory.SubchannelImpl

java.lang.Object

io.grpc.LoadBalancer.Subchannel

io.grpc.util.ForwardingSubchannel

io.grpc.protobuf.services.HealthCheckingLoadBalancerFactory.SubchannelImpl

Enclosing class:

HealthCheckingLoadBalancerFactory

static final class HealthCheckingLoadBalancerFactory.SubchannelImpl
extends ForwardingSubchannel

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final LoadBalancer.Subchannel	delegate
(package private) final HealthCheckingLoadBalancerFactory.HealthCheckState	hcState

Constructor Summary

Constructors

Constructor	Description
SubchannelImpl(LoadBalancer.Subchannel delegate, HealthCheckingLoadBalancerFactory.HealthCheckState hcState)

Method Summary

Modifier and Type	Method	Description
protected LoadBalancer.Subchannel	delegate()	Returns the underlying Subchannel.
void	start(LoadBalancer.SubchannelStateListener listener)	Starts the Subchannel.

Methods inherited from class ForwardingSubchannel

asChannel, getAllAddresses, getAttributes, getChannelLogger, getConnectedAddressAttributes, getInternalSubchannel, requestConnection, shutdown, toString, updateAddresses

Methods inherited from class LoadBalancer.Subchannel

getAddresses

Methods inherited from class Object

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

Field Details

delegate

final LoadBalancer.Subchannel delegate

hcState

final HealthCheckingLoadBalancerFactory.HealthCheckState hcState

Constructor Details

SubchannelImpl

SubchannelImpl(LoadBalancer.Subchannel delegate,
 HealthCheckingLoadBalancerFactory.HealthCheckState hcState)

Method Details

delegate

protected LoadBalancer.Subchannel delegate()

Description copied from class: ForwardingSubchannel

Returns the underlying Subchannel.

Specified by:

delegate in class ForwardingSubchannel

start

public void start(LoadBalancer.SubchannelStateListener listener)

Description copied from class: LoadBalancer.Subchannel

Starts the Subchannel. Can only be called once.

Must be called prior to any other method on this class, except for LoadBalancer.Subchannel.shutdown() which may be called at any time.

Must be called from the Synchronization Context, otherwise it may throw. See #5015 for more discussions.

Overrides:

start in class ForwardingSubchannel

Parameters:

listener - receives state updates for this Subchannel.