Method Build

internal/xds/balancer/outlierdetection/balancer.go:80–98

(cc balancer.ClientConn, bOpts balancer.BuildOptions)

type bb struct{}

func (bb) Build(cc balancer.ClientConn, bOpts balancer.BuildOptions) balancer.Balancer {
	b := &outlierDetectionBalancer{
		ClientConn:      cc,
		closed:          grpcsync.NewEvent(),
		done:            grpcsync.NewEvent(),
		addrs:           make(map[string]*endpointInfo),
		scUpdateCh:      buffer.NewUnbounded(),
		pickerUpdateCh:  buffer.NewUnbounded(),
		channelzParent:  bOpts.ChannelzParent,
		endpoints:       resolver.NewEndpointMap[*endpointInfo](),
		metricsRecorder: cc.MetricsRecorder(), // we use an explicit field instead of using cc.MetricsRecorder() so we can override the metric recorder in tests.
		target:          bOpts.Target.String(),
	}
	b.logger = prefixLogger(b)
	b.logger.Infof("Created")
	b.child = synchronizingBalancerWrapper{lb: gracefulswitch.NewBalancer(b, bOpts)}
	go b.run()
	return b
}

func (bb) ParseConfig(s json.RawMessage) (serviceconfig.LoadBalancingConfig, error) {
	lbCfg := &LBConfig{