Package io.grpc.rls
Class SubchannelStateManagerImpl
- java.lang.Object
-
- io.grpc.rls.SubchannelStateManagerImpl
-
- All Implemented Interfaces:
SubchannelStateManager
final class SubchannelStateManagerImpl extends java.lang.Object implements SubchannelStateManager
Implementation ofSubchannelStateManager
.
-
-
Field Summary
Fields Modifier and Type Field Description private ConnectivityState
currentState
private java.util.HashMap<java.lang.String,ConnectivityState>
stateMap
private com.google.common.collect.Multiset<ConnectivityState>
stateMultiset
-
Constructor Summary
Constructors Constructor Description SubchannelStateManagerImpl()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ConnectivityState
getAggregatedState()
Returns representative subchannel status from all registered subchannels.ConnectivityState
getState(java.lang.String name)
Returns current subchannel state for given subchannel name if exists, otherwise returnsnull
.java.lang.String
toString()
void
updateState(java.lang.String name, ConnectivityState newState)
Registers and updates state for given subchannel.
-
-
-
Field Detail
-
stateMap
private final java.util.HashMap<java.lang.String,ConnectivityState> stateMap
-
stateMultiset
private final com.google.common.collect.Multiset<ConnectivityState> stateMultiset
-
currentState
private ConnectivityState currentState
-
-
Method Detail
-
updateState
public void updateState(java.lang.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 interfaceSubchannelStateManager
-
getState
@Nullable public ConnectivityState getState(java.lang.String name)
Description copied from interface:SubchannelStateManager
Returns current subchannel state for given subchannel name if exists, otherwise returnsnull
.- Specified by:
getState
in interfaceSubchannelStateManager
-
getAggregatedState
public ConnectivityState getAggregatedState()
Description copied from interface:SubchannelStateManager
Returns representative subchannel status from all registered subchannels.- Specified by:
getAggregatedState
in interfaceSubchannelStateManager
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-