Class HealthProducerHelper.HealthProducerSubchannel

java.lang.Object

io.grpc.LoadBalancer.Subchannel

io.grpc.util.ForwardingSubchannel

io.grpc.util.HealthProducerHelper.HealthProducerSubchannel

Enclosing class:

HealthProducerHelper

static final class HealthProducerHelper.HealthProducerSubchannel
extends ForwardingSubchannel

Field Summary

Fields

Modifier and Type	Field	Description
private final LoadBalancer.Subchannel	delegate
private final LoadBalancer.SubchannelStateListener	healthListener

Constructor Summary

Constructors

Constructor	Description
HealthProducerSubchannel(LoadBalancer.Subchannel delegate, LoadBalancer.SubchannelStateListener healthListener)

Method Summary

Modifier and Type	Method	Description
LoadBalancer.Subchannel	delegate()	Returns the underlying Subchannel.
Attributes	getAttributes()	The same attributes passed to Helper.createSubchannel().
void	start(LoadBalancer.SubchannelStateListener listener)	Starts the Subchannel.

Methods inherited from class ForwardingSubchannel

asChannel, getAllAddresses, 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

private final LoadBalancer.Subchannel delegate

healthListener

private final LoadBalancer.SubchannelStateListener healthListener

Constructor Details

HealthProducerSubchannel

HealthProducerSubchannel(LoadBalancer.Subchannel delegate,
 LoadBalancer.SubchannelStateListener healthListener)

Method Details

delegate

public 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.

getAttributes

public Attributes getAttributes()

Description copied from class: LoadBalancer.Subchannel

The same attributes passed to Helper.createSubchannel(). LoadBalancer can use it to attach additional information here, e.g., the shard this Subchannel belongs to.

Overrides:

getAttributes in class ForwardingSubchannel