Build creates a new orcab balancer.
(cc balancer.ClientConn, bOpts balancer.BuildOptions)
| 46 | |
| 47 | // Build creates a new orcab balancer. |
| 48 | func (orcabb) Build(cc balancer.ClientConn, bOpts balancer.BuildOptions) balancer.Balancer { |
| 49 | b := &orcab{ |
| 50 | ClientConn: cc, |
| 51 | stopOOBListeners: make(map[balancer.SubConn]func()), |
| 52 | oobState: &oobState{ |
| 53 | reports: make(map[balancer.SubConn]*v3orcapb.OrcaLoadReport), |
| 54 | }, |
| 55 | } |
| 56 | b.logger = internalgrpclog.NewPrefixLogger(orcaLogger, fmt.Sprintf("[%p] ", b)) |
| 57 | b.child = endpointsharding.NewBalancer(b, bOpts, balancer.Get(pickfirst.Name).Build, endpointsharding.Options{}) |
| 58 | b.logger.Infof("Created") |
| 59 | return b |
| 60 | } |
| 61 | |
| 62 | func (orcabb) Name() string { |
| 63 | return "test_backend_metrics_load_balancer" |
nothing calls this directly
no test coverage detected