type google.golang.org/grpc/connectivity.State
30 uses
google.golang.org/grpc/connectivity (current package)
connectivity.go#L31: type State int
connectivity.go#L33: func (s State) String() string {
connectivity.go#L53: Idle State = iota
google.golang.org/grpc
balancer_wrapper.go#L291: connectivityState connectivity.State
balancer_wrapper.go#L298: func newHealthData(s connectivity.State) *healthData {
balancer_wrapper.go#L307: func (acbw *acBalancerWrapper) updateState(s connectivity.State, err error) {
clientconn.go#L598: state connectivity.State
clientconn.go#L607: func (csm *connectivityStateManager) updateState(state connectivity.State) {
clientconn.go#L628: func (csm *connectivityStateManager) getState() connectivity.State {
clientconn.go#L712: func (cc *ClientConn) WaitForStateChange(ctx context.Context, sourceState connectivity.State) bool {
clientconn.go#L726: func (cc *ClientConn) GetState() connectivity.State {
clientconn.go#L1266: state connectivity.State
clientconn.go#L1279: func (ac *addrConn) updateConnectivityState(s connectivity.State, lastErr error) {
clientconn.go#L1650: setConnectivityState := func(s connectivity.State, lastErr error) {
google.golang.org/grpc/balancer
balancer.go#L121: ConnectivityState connectivity.State
conn_state_evaluator.go#L43: func (cse *ConnectivityStateEvaluator) RecordTransition(oldState, newState connectivity.State) connectivity.State {
conn_state_evaluator.go#L45: for idx, state := range []connectivity.State{oldState, newState} {
conn_state_evaluator.go#L62: func (cse *ConnectivityStateEvaluator) CurrentState() connectivity.State {
subconn.go#L110: ConnectivityState connectivity.State
google.golang.org/grpc/balancer/base
balancer.go#L45: scStates: make(map[balancer.SubConn]connectivity.State),
balancer.go#L66: state connectivity.State
balancer.go#L69: scStates map[balancer.SubConn]connectivity.State
google.golang.org/grpc/balancer/endpointsharding
endpointsharding.go#L277: var aggState connectivity.State
google.golang.org/grpc/balancer/pickfirst
pickfirst.go#L159: rawConnectivityState connectivity.State
pickfirst.go#L162: effectiveState connectivity.State
pickfirst.go#L199: state connectivity.State
google.golang.org/grpc/internal
internal.go#L259: type HealthChecker func(ctx context.Context, newStream func(string) (any, error), setConnectivityState func(connectivity.State, error), serviceName string) error
google.golang.org/grpc/internal/channelz
channel.go#L95: State atomic.Pointer[connectivity.State]
channel.go#L160: func NewChannelMetricForTesting(state connectivity.State, target string, started, succeeded, failed, timestamp int64) *ChannelMetrics {