newConnectivityStateManager creates an connectivityStateManager with the specified channel.
(ctx context.Context, channel *channelz.Channel)
| 581 | // newConnectivityStateManager creates an connectivityStateManager with |
| 582 | // the specified channel. |
| 583 | func newConnectivityStateManager(ctx context.Context, channel *channelz.Channel) *connectivityStateManager { |
| 584 | return &connectivityStateManager{ |
| 585 | channelz: channel, |
| 586 | pubSub: grpcsync.NewPubSub(ctx), |
| 587 | } |
| 588 | } |
| 589 | |
| 590 | // connectivityStateManager keeps the connectivity.State of ClientConn. |
| 591 | // This struct will eventually be exported so the balancers can access it. |