Package io.grpc.util

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 LoadBalancer.Subchannel	delegate
private 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 io.grpc.util.ForwardingSubchannel

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

Methods inherited from class io.grpc.LoadBalancer.Subchannel

getAddresses

Methods inherited from class java.lang.Object

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

Field Detail

delegate

private final LoadBalancer.Subchannel delegate

healthListener

private final LoadBalancer.SubchannelStateListener healthListener

Constructor Detail

HealthProducerSubchannel

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

Method Detail

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