Function New

balancer/weightedtarget/weightedaggregator/aggregator.go:82–90

New creates a new weighted balancer state aggregator.

(cc balancer.ClientConn, logger *grpclog.PrefixLogger, newWRR func() wrr.WRR)

// New creates a new weighted balancer state aggregator.
func New(cc balancer.ClientConn, logger *grpclog.PrefixLogger, newWRR func() wrr.WRR) *Aggregator {
	return &Aggregator{
		cc:              cc,
		logger:          logger,
		newWRR:          newWRR,
		csEvltr:         &balancer.ConnectivityStateEvaluator{},
		idToPickerState: make(map[string]*weightedPickerState),
	}
}

// Start starts the aggregator. It can be called after Stop to restart the
// aggregator.