Function NewCmd

internal/cmd/manager/instance/run/cmd.go:78–155

NewCmd creates the "instance run" subcommand

()

// NewCmd creates the "instance run" subcommand
func NewCmd() *cobra.Command {
	var pgData string
	var podName string
	var clusterName string
	var namespace string
	var pprofHTTPServer bool
	var statusPortTLS bool
	var metricsPortTLS bool

	cmd := &cobra.Command{
		Use: "run [flags]",
		PreRunE: func(cmd *cobra.Command, _ []string) error {
			return management.WaitForGetCluster(cmd.Context(), client.ObjectKey{
				Name:      clusterName,
				Namespace: namespace,
			})
		},
		RunE: func(cmd *cobra.Command, _ []string) error {
			ctx := log.IntoContext(
				cmd.Context(),
				log.GetLogger().WithValues("logger", "instance-manager"),
			)

			checkCurrentOSRelease(ctx)

			instance := postgres.NewInstance().
				WithPodName(podName).
				WithClusterName(clusterName).
				WithNamespace(namespace)

			instance.PgData = pgData
			instance.StatusPortTLS = statusPortTLS
			instance.MetricsPortTLS = metricsPortTLS

			// Since version 0.19.0 of controller-runtime, it is not allowed to create multiple controllers with the
			// same name. As this part of the code is run inside a retry block, we need to allow SkipNameValidation
			// only on retries, because a previous run may have already created a controller
			// Reference https://github.com/kubernetes-sigs/controller-runtime/releases/tag/v0.19.0
			var skipNameValidation bool
			err := retry.OnError(retry.DefaultRetry, isRunSubCommandRetryable, func() error {
				defer func() { skipNameValidation = true }()
				return runSubCommand(ctx, instance, pprofHTTPServer, skipNameValidation)
			})

			if errors.Is(err, postgres.ErrNoFreeWALSpace) {
				os.Exit(apiv1.MissingWALDiskSpaceExitCode)
			}

			return err
		},
		PostRunE: func(cmd *cobra.Command, _ []string) error {
			if err := istio.TryInvokeQuitEndpoint(cmd.Context()); err != nil {
				return err
			}

			return linkerd.TryInvokeShutdownEndpoint(cmd.Context())
		},
	}