INNER CODE UNIT · Go

getLabelsAndAnnotationsToCopy

kubernetes-sigs/kueue · cmd/kueue/main.go:623

func getLabelsAndAnnotationsToCopy(cfg *configapi.Configuration) (labelKeysToCopy sets.Set[string], annotationsToCopy sets.Set[string]) {
	if !features.Enabled(features.CustomMetricLabels) {
		return sets.New(cfg.Integrations.LabelKeysToCopy...), sets.New[string]()
	}
	labelKeysToCopy, annotationsToCopy = metrics.WorkloadCustomLabelSources(cfg.Metrics.CustomLabels)
	labelKeysToCopy.Insert(cfg.Integrations.LabelKeysToCopy...)
	return
}

// setupProbeEndpoints registers the health endpoints
func setupProbeEndpoints(mgr ctrl.Manager, certsReady <-chan struct{}) error {
	defer setupLog.Info("Probe endpoints are configured on healthz and readyz")

	if err := mgr.AddHealthzCheck("healthz", healthz.Ping); err != nil {
		return fmt.Errorf("unable to set up health check: %w", err)
	}

	// Wait for the webhook server to be listening before advertising the

View source record →