Method Build

orca/producer.go:40–56

Build constructs and returns a producer and its cleanup function

(cci any)

// Build constructs and returns a producer and its cleanup function
func (*producerBuilder) Build(cci any) (balancer.Producer, func()) {
	p := &producer{
		client:    v3orcaservicegrpc.NewOpenRcaServiceClient(cci.(grpc.ClientConnInterface)),
		intervals: make(map[time.Duration]int),
		listeners: make(map[OOBListener]struct{}),
		backoff:   internal.DefaultBackoffFunc,
	}
	return p, func() {
		p.mu.Lock()
		if p.stop != nil {
			p.stop()
			p.stop = nil
		}
		p.mu.Unlock()
		<-p.stopped
	}
}

var producerBuilderSingleton = &producerBuilder{}