resolverError is invoked by grpc to push a resolver error to the underlying balancer. The call to the balancer is executed from the serializer.
(err error)
| 141 | // resolverError is invoked by grpc to push a resolver error to the underlying |
| 142 | // balancer. The call to the balancer is executed from the serializer. |
| 143 | func (ccb *ccBalancerWrapper) resolverError(err error) { |
| 144 | ccb.serializer.TrySchedule(func(ctx context.Context) { |
| 145 | if ctx.Err() != nil || ccb.balancer == nil { |
| 146 | return |
| 147 | } |
| 148 | ccb.balancer.ResolverError(err) |
| 149 | }) |
| 150 | } |
| 151 | |
| 152 | // close initiates async shutdown of the wrapper. cc.mu must be held when |
| 153 | // calling this function. To determine the wrapper has finished shutting down, |
no test coverage detected