Method Run

cmd/restart.go:73–192

Run executes the purge command logic

(f factory.Factory)

// Run executes the purge command logic
func (cmd *RestartCmd) Run(f factory.Factory) error {
	// Set config root
	cmd.log = f.GetLog()
	configOptions := cmd.ToConfigOptions()
	configLoader, err := f.NewConfigLoader(cmd.ConfigPath)
	if err != nil {
		return err
	}
	configExists, err := configLoader.SetDevSpaceRoot(cmd.log)
	if err != nil {
		return err
	} else if !configExists || cmd.Pod != "" || cmd.LabelSelector != "" || cmd.Pick {
		client, err := f.NewKubeClientFromContext(cmd.KubeContext, cmd.Namespace)
		if err != nil {
			return errors.Wrap(err, "create kube client")
		}

		// Create context
		ctx := devspacecontext.NewContext(context.Background(), nil, cmd.log).
			WithKubeClient(client)

		return restartContainer(ctx, targetselector.NewOptionsFromFlags(cmd.Container, cmd.LabelSelector, nil, cmd.Namespace, cmd.Pod).WithPick(cmd.Pick))
	}

	log.StartFileLogging()

	client, err := f.NewKubeClientFromContext(cmd.KubeContext, cmd.Namespace)
	if err != nil {
		return errors.Wrap(err, "create kube client")
	}

	localCache, err := configLoader.LoadLocalCache()
	if err != nil {
		return err
	}

	// If the current kube context or namespace is different from old,
	// show warnings and reset kube client if necessary
	client, err = kubectl.CheckKubeContext(client, localCache, cmd.NoWarn, cmd.SwitchContext, false, cmd.log)
	if err != nil {
		return err
	}

	// Get config with adjusted cluster config
	config, err := configLoader.LoadWithCache(context.Background(), localCache, client, configOptions, cmd.log)
	if err != nil {
		return err
	}

	// Create context
	ctx := devspacecontext.NewContext(context.Background(), config.Variables(), cmd.log).
		WithConfig(config).
		WithKubeClient(client)

	// Execute plugin hook
	err = hook.ExecuteHooks(ctx, nil, "restart")
	if err != nil {
		return err