gather PGUpgrade resource

internal/cmd/export.go

@@ -561,6 +561,22 @@ Collecting PGO CLI logs...
 			writeInfo(cmd, fmt.Sprintf("Error gathering kubectl plugins: %s", err))
 		}
 
+		// Get PGUpgrade spec (if available)
+		writeInfo(cmd, "Collecting PGUpgrade spec (if available)...")
+
+		key := util.AllowUpgradeAnnotation()
+		value, exists := get.GetAnnotations()[key]
+
+		if exists {
+			writeInfo(cmd, fmt.Sprintf("The PGUpgrade object is: %s", value))
+			err = gatherPGUpgradeSpec(clusterName, namespace, value, tw, cmd)
+			if err != nil {
+				writeInfo(cmd, fmt.Sprintf("Error gathering PGUpgrade spec: %s", err))
+			}
+		} else {
+			writeInfo(cmd, fmt.Sprintf("There is no PGUpgrade object associated with cluster '%s'", clusterName))
+		}
+
 		// Print cli output
 		writeInfo(cmd, "Collecting PGO CLI logs...")
 		path := clusterName + "/cli.log"
@@ -579,7 +595,10 @@ Collecting PGO CLI logs...
 }
 
 func gatherPluginList(clusterName string, tw *tar.Writer, cmd *cobra.Command) error {
-	ex := exec.Command("kubectl", "plugin", "list")
+	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
+	defer cancel() // Ensure the context is canceled to avoid leaks
+
+	ex := exec.CommandContext(ctx, "kubectl", "plugin", "list")
 	msg, err := ex.Output()
 
 	if err != nil {
@@ -594,6 +613,29 @@ func gatherPluginList(clusterName string, tw *tar.Writer, cmd *cobra.Command) er
 	return nil
 }
 
+func gatherPGUpgradeSpec(clusterName, namespace, pgUpgrade string, tw *tar.Writer, cmd *cobra.Command) error {
+	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
+	defer cancel() // Ensure the context is canceled to avoid leaks
+
+	ex := exec.CommandContext(ctx, "kubectl", "get", "pgupgrade", pgUpgrade, "-n", namespace, "-o", "yaml")
+	msg, err := ex.Output()
+
+	if err != nil {
+		msg = append(msg, err.Error()...)
+		msg = append(msg, []byte(`
+There was an error running 'kubectl get pgupgrade'. Verify permissions and that the resource exists.`)...)
+
+		writeInfo(cmd, fmt.Sprintf("Error: '%s'", msg))
+	}
+
+	path := clusterName + "/pgupgrade.yaml"
+	if err := writeTar(tw, msg, path, cmd); err != nil {
+		return err
+	}
+
+	return nil
+}
+
 // exportSizeReport defines the message displayed when a support export archive
 // is created. If the size of the archive file is greater than 25MiB, an alternate
 // message is displayed.

internal/util/naming.go

@@ -89,3 +89,9 @@ func PostgresUserSecretLabels(clusterName string) string {
 	return LabelCluster + "=" + clusterName + "," +
 		LabelRole + "=" + RolePostgresUser
 }
+
+// AllowUpgradeAnnotation is the annotation key to allow of PostgresCluster
+// to upgrade. Its value is the name of the PGUpgrade object.
+func AllowUpgradeAnnotation() string {
+	return labelPrefix + "allow-upgrade"
+}