(cc balancer.ClientConn, bOpts balancer.BuildOptions)
| 51 | type bb struct{} |
| 52 | |
| 53 | func (bb) Build(cc balancer.ClientConn, bOpts balancer.BuildOptions) balancer.Balancer { |
| 54 | b := &weightedTargetBalancer{} |
| 55 | b.logger = prefixLogger(b) |
| 56 | b.stateAggregator = weightedaggregator.New(cc, b.logger, NewRandomWRR) |
| 57 | b.stateAggregator.Start() |
| 58 | b.bg = balancergroup.New(balancergroup.Options{ |
| 59 | CC: cc, |
| 60 | BuildOpts: bOpts, |
| 61 | StateAggregator: b.stateAggregator, |
| 62 | Logger: b.logger, |
| 63 | SubBalancerCloseTimeout: time.Duration(0), // Disable caching of removed child policies |
| 64 | }) |
| 65 | b.logger.Infof("Created") |
| 66 | return b |
| 67 | } |
| 68 | |
| 69 | func (bb) Name() string { |
| 70 | return Name |
nothing calls this directly
no test coverage detected