Package io.grpc.rls

Class SubchannelStateManagerImpl

java.lang.Object

io.grpc.rls.SubchannelStateManagerImpl

All Implemented Interfaces:

SubchannelStateManager

final class SubchannelStateManagerImpl
extends Object
implements SubchannelStateManager

Implementation of SubchannelStateManager.

Field Summary

Fields

Modifier and Type	Field	Description
private ConnectivityState	currentState
private final HashMap<String,ConnectivityState>	stateMap
private final com.google.common.collect.Multiset<ConnectivityState>	stateMultiset

Constructor Summary

Constructors

Constructor	Description
SubchannelStateManagerImpl()

Method Summary

Modifier and Type	Method	Description
ConnectivityState	getAggregatedState()	Returns representative subchannel status from all registered subchannels.
ConnectivityState	getState(String name)	Returns current subchannel state for given subchannel name if exists, otherwise returns null.
String	toString()
void	updateState(String name, ConnectivityState newState)	Registers and updates state for given subchannel.

Methods inherited from class java.lang.Object

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

Field Details

stateMap

private final HashMap<String,ConnectivityState> stateMap

stateMultiset

private final com.google.common.collect.Multiset<ConnectivityState> stateMultiset

currentState

private ConnectivityState currentState

Constructor Details

SubchannelStateManagerImpl

SubchannelStateManagerImpl()

Method Details

updateState

public void updateState(String name,
 ConnectivityState newState)

Description copied from interface: SubchannelStateManager

Registers and updates state for given subchannel. ConnectivityState.SHUTDOWN unregisters the subchannel.

Specified by:

updateState in interface SubchannelStateManager

getState

@Nullable
public ConnectivityState getState(String name)

Description copied from interface: SubchannelStateManager

Returns current subchannel state for given subchannel name if exists, otherwise returns null.

Specified by:

getState in interface SubchannelStateManager

getAggregatedState

public ConnectivityState getAggregatedState()

Description copied from interface: SubchannelStateManager

Returns representative subchannel status from all registered subchannels.

Specified by:

getAggregatedState in interface SubchannelStateManager

toString

public String toString()

Overrides:

toString in class Object