type google.golang.org/grpc/balancer.SubConnState
35 uses
google.golang.org/grpc/balancer (current package)
balancer.go#L114: StateListener func(SubConnState)
balancer.go#L358: UpdateSubConnState(SubConn, SubConnState)
subconn.go#L87: RegisterHealthListener(func(SubConnState))
subconn.go#L108: type SubConnState struct {
subconn.go#L121: func connectedAddress(scs SubConnState) resolver.Address {
subconn.go#L126: func setConnectedAddress(scs *SubConnState, addr resolver.Address) {
google.golang.org/grpc/balancer/base
balancer.go#L111: StateListener: func(scs balancer.SubConnState) { b.updateSubConnState(sc, scs) },
balancer.go#L184: func (b *baseBalancer) UpdateSubConnState(sc balancer.SubConn, state balancer.SubConnState) {
balancer.go#L188: func (b *baseBalancer) updateSubConnState(sc balancer.SubConn, state balancer.SubConnState) {
google.golang.org/grpc/balancer/endpointsharding
endpointsharding.go#L220: func (es *endpointSharding) UpdateSubConnState(balancer.SubConn, balancer.SubConnState) {
google.golang.org/grpc/balancer/pickfirst
pickfirst.go#L183: StateListener: func(state balancer.SubConnState) {
pickfirst.go#L210: func (b *pickfirstBalancer) UpdateSubConnState(subConn balancer.SubConn, state balancer.SubConnState) {
pickfirst.go#L214: func (b *pickfirstBalancer) updateSubConnState(subConn balancer.SubConn, state balancer.SubConnState) {
google.golang.org/grpc/balancer/pickfirst/pickfirstleaf
pickfirstleaf.go#L175: StateListener: func(state balancer.SubConnState) {
pickfirstleaf.go#L335: func (b *pickfirstBalancer) UpdateSubConnState(subConn balancer.SubConn, state balancer.SubConnState) {
pickfirstleaf.go#L578: func (b *pickfirstBalancer) updateSubConnState(sd *scData, newState balancer.SubConnState) {
pickfirstleaf.go#L632: sd.subConn.RegisterHealthListener(func(scs balancer.SubConnState) {
pickfirstleaf.go#L756: func (b *pickfirstBalancer) updateSubConnHealthState(sd *scData, state balancer.SubConnState) {
google.golang.org/grpc
balancer_wrapper.go#L39: setConnectedAddress = internal.SetConnectedAddress.(func(*balancer.SubConnState, resolver.Address))
balancer_wrapper.go#L42: noOpRegisterHealthListenerFn = func(_ context.Context, listener func(balancer.SubConnState)) func() {
balancer_wrapper.go#L43: listener(balancer.SubConnState{ConnectivityState: connectivity.Ready})
balancer_wrapper.go#L274: stateListener func(balancer.SubConnState)
balancer_wrapper.go#L319: scs := balancer.SubConnState{ConnectivityState: s, ConnectionError: err}
balancer_wrapper.go#L438: type healthProducerRegisterFn = func(context.Context, balancer.SubConn, string, func(balancer.SubConnState)) func()
balancer_wrapper.go#L449: func (acbw *acBalancerWrapper) healthListenerRegFn() func(context.Context, func(balancer.SubConnState)) func() {
balancer_wrapper.go#L462: return func(ctx context.Context, listener func(balancer.SubConnState)) func() {
balancer_wrapper.go#L472: func (acbw *acBalancerWrapper) RegisterHealthListener(listener func(balancer.SubConnState)) {
balancer_wrapper.go#L504: listenerWrapper := func(scs balancer.SubConnState) {
google.golang.org/grpc/health
producer.go#L66: func registerClientSideHealthCheckListener(ctx context.Context, sc balancer.SubConn, serviceName string, listener func(balancer.SubConnState)) func() {
producer.go#L83: func (p *healthServiceProducer) startHealthCheck(ctx context.Context, sc balancer.SubConn, serviceName string, listener func(balancer.SubConnState)) {
producer.go#L89: listener(balancer.SubConnState{
google.golang.org/grpc/internal/balancer/gracefulswitch
gracefulswitch.go#L230: func (gsb *Balancer) updateSubConnState(sc balancer.SubConn, state balancer.SubConnState, cb func(balancer.SubConnState)) {
gracefulswitch.go#L261: func (gsb *Balancer) UpdateSubConnState(sc balancer.SubConn, state balancer.SubConnState) {
gracefulswitch.go#L370: opts.StateListener = func(state balancer.SubConnState) { bw.gsb.updateSubConnState(sc, state, oldListener) }