(s balancer.ClientConnState)
| 92 | } |
| 93 | |
| 94 | func (b *rpcBehaviorLB) UpdateClientConnState(s balancer.ClientConnState) error { |
| 95 | lbCfg, ok := s.BalancerConfig.(*lbConfig) |
| 96 | if !ok { |
| 97 | return fmt.Errorf("test.RpcBehaviorLoadBalancer:received config with unexpected type %T: %s", s.BalancerConfig, pretty.ToJSON(s.BalancerConfig)) |
| 98 | } |
| 99 | b.mu.Lock() |
| 100 | b.cfg = lbCfg |
| 101 | b.mu.Unlock() |
| 102 | return b.Balancer.UpdateClientConnState(balancer.ClientConnState{ |
| 103 | ResolverState: s.ResolverState, |
| 104 | }) |
| 105 | } |
| 106 | |
| 107 | func (b *rpcBehaviorLB) UpdateState(state balancer.State) { |
| 108 | b.mu.Lock() |
nothing calls this directly
no test coverage detected