Uses of Class
io.grpc.ConnectivityState
-
Packages that use ConnectivityState Package Description io.grpc The gRPC core public API.io.grpc.grpclb io.grpc.internal Interfaces and implementations that are internal to gRPC.io.grpc.protobuf.services Service definitions and utilities with protobuf dependency for the pre-defined gRPC services.io.grpc.rls io.grpc.util Utilities with advanced features in the core layer that user can optionally use. -
-
Uses of ConnectivityState in io.grpc
Fields in io.grpc declared as ConnectivityState Modifier and Type Field Description private ConnectivityState
ConnectivityStateInfo. state
private ConnectivityState
InternalChannelz.ChannelStats.Builder. state
ConnectivityState
InternalChannelz.ChannelStats. state
Methods in io.grpc that return ConnectivityState Modifier and Type Method Description ConnectivityState
ConnectivityStateInfo. getState()
Returns the state.ConnectivityState
ManagedChannel. getState(boolean requestConnection)
Gets the current connectivity state.static ConnectivityState
ConnectivityState. valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.static ConnectivityState[]
ConnectivityState. values()
Returns an array containing the constants of this enum type, in the order they are declared.Methods in io.grpc with parameters of type ConnectivityState Modifier and Type Method Description static ConnectivityStateInfo
ConnectivityStateInfo. forNonError(ConnectivityState state)
Returns an instance for a state that is notTRANSIENT_FAILURE
.void
ManagedChannel. notifyWhenStateChanged(ConnectivityState source, java.lang.Runnable callback)
Registers a one-off callback that will be run if the connectivity state of the channel diverges from the givensource
, which is typically what has just been returned byManagedChannel.getState(boolean)
.InternalChannelz.ChannelStats.Builder
InternalChannelz.ChannelStats.Builder. setState(ConnectivityState state)
abstract void
LoadBalancer.Helper. updateBalancingState(ConnectivityState newState, LoadBalancer.SubchannelPicker newPicker)
Set a new state with a new picker to the channel.Constructors in io.grpc with parameters of type ConnectivityState Constructor Description ChannelStats(java.lang.String target, ConnectivityState state, InternalChannelz.ChannelTrace channelTrace, long callsStarted, long callsSucceeded, long callsFailed, long lastCallStartedNanos, java.util.List<InternalWithLogId> subchannels, java.util.List<InternalWithLogId> sockets)
Creates an instance.ConnectivityStateInfo(ConnectivityState state, Status status)
-
Uses of ConnectivityState in io.grpc.grpclb
Methods in io.grpc.grpclb with parameters of type ConnectivityState Modifier and Type Method Description private void
GrpclbState. maybeUpdatePicker(ConnectivityState state, GrpclbState.RoundRobinPicker picker)
Update the given picker to the helper if it's different from the current one. -
Uses of ConnectivityState in io.grpc.internal
Fields in io.grpc.internal declared as ConnectivityState Modifier and Type Field Description private ConnectivityState
PickFirstLeafLoadBalancer. concludedState
private ConnectivityState
PickFirstLoadBalancer. currentState
private ConnectivityState
PickFirstLeafLoadBalancer. rawConnectivityState
private ConnectivityState
ConnectivityStateManager. state
private ConnectivityState
PickFirstLeafLoadBalancer.SubchannelData. state
Methods in io.grpc.internal that return ConnectivityState Modifier and Type Method Description (package private) ConnectivityState
PickFirstLeafLoadBalancer. getConcludedConnectivityState()
private ConnectivityState
PickFirstLeafLoadBalancer.SubchannelData. getHealthState()
(package private) ConnectivityState
ConnectivityStateManager. getState()
Gets the current connectivity state of the channel.ConnectivityState
ForwardingManagedChannel. getState(boolean requestConnection)
(package private) ConnectivityState
InternalSubchannel. getState()
ConnectivityState
ManagedChannelImpl. getState(boolean requestConnection)
ConnectivityState
OobChannel. getState(boolean requestConnectionIgnored)
ConnectivityState
PickFirstLeafLoadBalancer.SubchannelData. getState()
Methods in io.grpc.internal with parameters of type ConnectivityState Modifier and Type Method Description private void
InternalSubchannel. gotoNonErrorState(ConnectivityState newState)
(package private) void
ConnectivityStateManager. gotoState(ConnectivityState newState)
Connectivity state is changed to the specified value.(package private) void
ConnectivityStateManager. notifyWhenStateChanged(java.lang.Runnable callback, java.util.concurrent.Executor executor, ConnectivityState source)
Adds a listener for state change event.void
ForwardingManagedChannel. notifyWhenStateChanged(ConnectivityState source, java.lang.Runnable callback)
void
ManagedChannelImpl. notifyWhenStateChanged(ConnectivityState source, java.lang.Runnable callback)
void
ManagedChannelImpl.LbHelperImpl. updateBalancingState(ConnectivityState newState, LoadBalancer.SubchannelPicker newPicker)
private void
PickFirstLeafLoadBalancer. updateBalancingState(ConnectivityState state, LoadBalancer.SubchannelPicker picker)
private void
PickFirstLoadBalancer. updateBalancingState(ConnectivityState state, LoadBalancer.SubchannelPicker picker)
private void
PickFirstLeafLoadBalancer.SubchannelData. updateState(ConnectivityState newState)
Constructors in io.grpc.internal with parameters of type ConnectivityState Constructor Description SubchannelData(LoadBalancer.Subchannel subchannel, ConnectivityState state)
-
Uses of ConnectivityState in io.grpc.protobuf.services
Methods in io.grpc.protobuf.services with parameters of type ConnectivityState Modifier and Type Method Description (package private) static ChannelConnectivityState
ChannelzProtoUtil. toChannelConnectivityState(ConnectivityState s)
(package private) static ChannelConnectivityState.State
ChannelzProtoUtil. toState(ConnectivityState state)
-
Uses of ConnectivityState in io.grpc.rls
Fields in io.grpc.rls declared as ConnectivityState Modifier and Type Field Description private ConnectivityState
SubchannelStateManagerImpl. currentState
private ConnectivityState
CachingRlsLbClient.BackoffRefreshListener. prevState
private ConnectivityState
CachingRlsLbClient.RlsLbHelper. state
private ConnectivityState
LbPolicyConfiguration.ChildPolicyWrapper. state
Fields in io.grpc.rls with type parameters of type ConnectivityState Modifier and Type Field Description private java.util.HashMap<java.lang.String,ConnectivityState>
SubchannelStateManagerImpl. stateMap
private com.google.common.collect.Multiset<ConnectivityState>
SubchannelStateManagerImpl. stateMultiset
Methods in io.grpc.rls that return ConnectivityState Modifier and Type Method Description ConnectivityState
SubchannelStateManager. getAggregatedState()
Returns representative subchannel status from all registered subchannels.ConnectivityState
SubchannelStateManagerImpl. getAggregatedState()
ConnectivityState
LbPolicyConfiguration.ChildPolicyWrapper. getState()
ConnectivityState
SubchannelStateManager. getState(java.lang.String name)
Returns current subchannel state for given subchannel name if exists, otherwise returnsnull
.ConnectivityState
SubchannelStateManagerImpl. getState(java.lang.String name)
Methods in io.grpc.rls with parameters of type ConnectivityState Modifier and Type Method Description void
CachingRlsLbClient.BackoffRefreshListener. onStatusChanged(ConnectivityState newState)
void
LbPolicyConfiguration.ChildLbStatusListener. onStatusChanged(ConnectivityState newState)
Notifies when child lb status changes.void
CachingRlsLbClient.RlsLbHelper. updateBalancingState(ConnectivityState newState, LoadBalancer.SubchannelPicker newPicker)
void
ChildLoadBalancerHelper. updateBalancingState(ConnectivityState newState, LoadBalancer.SubchannelPicker unused)
Updates balancing state from one or more subchannels tracked in theSubchannelStateManager
.void
LbPolicyConfiguration.ChildPolicyWrapper.ChildPolicyReportingHelper. updateBalancingState(ConnectivityState newState, LoadBalancer.SubchannelPicker newPicker)
void
SubchannelStateManager. updateState(java.lang.String name, ConnectivityState newState)
Registers and updates state for given subchannel.void
SubchannelStateManagerImpl. updateState(java.lang.String name, ConnectivityState newState)
-
Uses of ConnectivityState in io.grpc.util
Fields in io.grpc.util declared as ConnectivityState Modifier and Type Field Description protected ConnectivityState
MultiChildLoadBalancer. currentConnectivityState
private ConnectivityState
MultiChildLoadBalancer.ChildLbState. currentState
private ConnectivityState
GracefulSwitchLoadBalancer. pendingState
Methods in io.grpc.util that return ConnectivityState Modifier and Type Method Description protected static ConnectivityState
MultiChildLoadBalancer. aggregateState(ConnectivityState overallState, ConnectivityState childState)
ConnectivityState
MultiChildLoadBalancer.ChildLbState. getCurrentState()
Methods in io.grpc.util with parameters of type ConnectivityState Modifier and Type Method Description protected static ConnectivityState
MultiChildLoadBalancer. aggregateState(ConnectivityState overallState, ConnectivityState childState)
protected void
MultiChildLoadBalancer.ChildLbState. setCurrentState(ConnectivityState newState)
void
ForwardingLoadBalancerHelper. updateBalancingState(ConnectivityState newState, LoadBalancer.SubchannelPicker newPicker)
void
MultiChildLoadBalancer.ChildLbState.ChildLbStateHelper. updateBalancingState(ConnectivityState newState, LoadBalancer.SubchannelPicker newPicker)
Update current state and picker for this child and then useMultiChildLoadBalancer.updateOverallBalancingState()
for the parent LB.void
OutlierDetectionLoadBalancer.ChildHelper. updateBalancingState(ConnectivityState newState, LoadBalancer.SubchannelPicker newPicker)
private void
RoundRobinLoadBalancer. updateBalancingState(ConnectivityState state, LoadBalancer.SubchannelPicker picker)
-