Function Run

cmd/app/cloudshell-manager.go:90–140

(ctx context.Context, config *config.Config)

}

func Run(ctx context.Context, config *config.Config) error {
	// To help debugging, immediately log version
	klog.Infof("cloudshell-controller-manager version: %s", version.Get())
	klog.InfoS("Golang settings", "GOGC", os.Getenv("GOGC"), "GOMAXPROCS", os.Getenv("GOMAXPROCS"), "GOTRACEBACK", os.Getenv("GOTRACEBACK"))

	if !config.LeaderElection.LeaderElect {
		return StartControllers(config, ctx.Done())
	}

	id, err := os.Hostname()
	if err != nil {
		return err
	}

	// add an uniquifier so that two processes on the same host don't accidentally both become active
	id += "_" + string(uuid.NewUUID())

	rl, err := resourcelock.NewFromKubeconfig(
		config.LeaderElection.ResourceLock,
		config.LeaderElection.ResourceNamespace,
		config.LeaderElection.ResourceName,
		resourcelock.ResourceLockConfig{
			Identity:      id,
			EventRecorder: config.EventRecorder,
		},
		config.Kubeconfig,
		config.LeaderElection.RenewDeadline.Duration,
	)
	if err != nil {
		return fmt.Errorf("failed to create resource lock: %w", err)
	}

	leaderelection.RunOrDie(context.TODO(), leaderelection.LeaderElectionConfig{
		Name:          config.LeaderElection.ResourceName,
		Lock:          rl,
		LeaseDuration: config.LeaderElection.LeaseDuration.Duration,
		RenewDeadline: config.LeaderElection.RenewDeadline.Duration,
		RetryPeriod:   config.LeaderElection.RetryPeriod.Duration,

		Callbacks: leaderelection.LeaderCallbacks{
			OnStartedLeading: func(_ context.Context) {
				_ = StartControllers(config, ctx.Done())
			},
			OnStoppedLeading: func() {
				klog.InfoS("leaderelection lost")
			},
		},
	})

	return nil
}

func StartControllers(c *config.Config, stopCh <-chan struct{}) error {
	ownerExist, err := labels.NewRequirement(constants.WorkerOwnerLabelKey, selection.Exists, nil)