code: func (cp *connProducer) UpdateEndpoints(endpoints []string) {
  	if len(endpoints) == 0 {
  		// Ignore updates with empty endpoints
  		return
  	}
  	cp.Lock()
  	defer cp.Unlock()
  
  	newDisabled := make(map[string]time.Time)
  	for i := range endpoints {
  		if startTime, ok := cp.disabledEndpoints[endpoints[i]]; ok {
  			newDisabled[endpoints[i]] = startTime
  		}
  	}
  	cp.endpoints = endpoints
  	cp.disabledEndpoints = newDisabled
  }
docs: // UpdateEndpoints updates the endpoints of the ConnectionProducer
  // to be the given endpoints