type google.golang.org/grpc/connectivity.State
32 uses
google.golang.org/grpc/connectivity (current package)
connectivity.go#L34: type State int
connectivity.go#L36: func (s State) String() string {
connectivity.go#L56: Idle State = iota
connectivity.go#L70: CurrentState() State
connectivity.go#L74: WaitForStateChange(context.Context, State) bool
google.golang.org/grpc
balancer_conn_wrappers.go#L36: state connectivity.State
balancer_conn_wrappers.go#L101: func (ccb *ccBalancerWrapper) handleSubConnStateChange(sc balancer.SubConn, s connectivity.State, err error) {
clientconn.go#L410: state connectivity.State
clientconn.go#L418: func (csm *connectivityStateManager) updateState(state connectivity.State) {
clientconn.go#L436: func (csm *connectivityStateManager) getState() connectivity.State {
clientconn.go#L512: func (cc *ClientConn) WaitForStateChange(ctx context.Context, sourceState connectivity.State) bool {
clientconn.go#L527: func (cc *ClientConn) GetState() connectivity.State {
clientconn.go#L703: func (cc *ClientConn) handleSubConnStateChange(sc balancer.SubConn, s connectivity.State, err error) {
clientconn.go#L1058: state connectivity.State
clientconn.go#L1068: func (ac *addrConn) updateConnectivityState(s connectivity.State, lastErr error) {
clientconn.go#L1357: setConnectivityState := func(s connectivity.State, lastErr error) {
clientconn.go#L1452: func (ac *addrConn) getState() connectivity.State {
pickfirst.go#L47: state connectivity.State
google.golang.org/grpc/balancer
balancer.go#L127: ConnectivityState connectivity.State
balancer.go#L318: ConnectivityState connectivity.State
balancer.go#L354: func (cse *ConnectivityStateEvaluator) RecordTransition(oldState, newState connectivity.State) connectivity.State {
balancer.go#L356: for idx, state := range []connectivity.State{oldState, newState} {
google.golang.org/grpc/balancer/base
balancer.go#L45: scStates: make(map[balancer.SubConn]connectivity.State),
balancer.go#L65: state connectivity.State
balancer.go#L68: scStates map[balancer.SubConn]connectivity.State
google.golang.org/grpc/balancer/grpclb
grpclb.go#L144: scStates: make(map[balancer.SubConn]connectivity.State),
grpclb.go#L211: state connectivity.State
grpclb.go#L213: scStates map[balancer.SubConn]connectivity.State // Used to filter READY SubConns.
grpclb.go#L293: func (lb *lbBalancer) aggregateSubConnStates() connectivity.State {
google.golang.org/grpc/internal
internal.go#L65: type HealthChecker func(ctx context.Context, newStream func(string) (interface{}, error), setConnectivityState func(connectivity.State, error), serviceName string) error
google.golang.org/grpc/internal/channelz
types.go#L141: State connectivity.State
 |
The pages are generated with Golds v0.3.2-preview. (GOOS=darwin GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @Go100and1 (reachable from the left QR code) to get the latest news of Golds. |