Issue 36: Add support for NGF - NGINX Gateway Fabric

cmd/nginx-supportpkg.go

@@ -25,6 +25,7 @@ import (
 	"github.com/nginxinc/nginx-k8s-supportpkg/pkg/version"
 	"github.com/spf13/cobra"
 	"os"
+	"slices"
 )
 
 func Execute() {
@@ -50,9 +51,11 @@ func Execute() {
 
 			switch product {
 			case "nic":
-				jobList = jobs.NICJobList()
+				jobList = slices.Concat(jobs.CommonJobList(), jobs.NICJobList())
+			case "ngf":
+				jobList = slices.Concat(jobs.CommonJobList(), jobs.NGFJobList())
 			default:
-				fmt.Printf("Error: product must be in the following list: [nic]\n")
+				fmt.Printf("Error: product must be in the following list: [nic, ngf]\n")
 				os.Exit(1)
 			}
 
@@ -101,8 +104,8 @@ func Execute() {
 			"Usage:" +
 			"\n nginx-supportpkg -h|--help" +
 			"\n nginx-supportpkg -v|--version" +
-			"\n nginx-supportpkg [-n|--namespace] ns1 [-n|--namespace] ns2 [-p|--product] nic" +
-			"\n nginx-supportpkg [-n|--namespace] ns1,ns2 [-p|--product] nic \n")
+			"\n nginx-supportpkg [-n|--namespace] ns1 [-n|--namespace] ns2 [-p|--product] [nic,ngf]" +
+			"\n nginx-supportpkg [-n|--namespace] ns1,ns2 [-p|--product] [nic,ngf] \n")
 
 	if err := rootCmd.Execute(); err != nil {
 		fmt.Println(err)

pkg/crds/crd.go

@@ -24,7 +24,7 @@ type Crd struct {
 	Version  string
 }
 
-func GetCRDList() []Crd {
+func GetNICCRDList() []Crd {
 	crdList := []Crd{
 		{
 			Resource: "apdoslogconfs",
@@ -84,3 +84,29 @@ func GetCRDList() []Crd {
 	}
 	return crdList
 }
+
+func GetNGFCRDList() []Crd {
+	crdList := []Crd{
+		{
+			Resource: "clientsettingspolicies",
+			Group:    "gateway.nginx.org",
+			Version:  "v1alpha1",
+		},
+		{
+			Resource: "nginxgateways",
+			Group:    "gateway.nginx.org",
+			Version:  "v1alpha1",
+		},
+		{
+			Resource: "nginxproxies",
+			Group:    "gateway.nginx.org",
+			Version:  "v1alpha1",
+		},
+		{
+			Resource: "observabilitypolicies",
+			Group:    "gateway.nginx.org",
+			Version:  "v1alpha1",
+		},
+	}
+	return crdList
+}

pkg/data_collector/data_collector.go

@@ -199,18 +199,19 @@ func (c *DataCollector) WrapUp(product string) (string, error) {
 	return tarballName, nil
 }
 
-func (c *DataCollector) PodExecutor(namespace string, pod string, command []string, ctx context.Context) ([]byte, error) {
+func (c *DataCollector) PodExecutor(namespace string, pod string, container string, command []string, ctx context.Context) ([]byte, error) {
 	req := c.K8sCoreClientSet.CoreV1().RESTClient().Post().
 		Namespace(namespace).
 		Resource("pods").
 		Name(pod).
 		SubResource("exec").
 		VersionedParams(&corev1.PodExecOptions{
-			Command: command,
-			Stdin:   false,
-			Stdout:  true,
-			Stderr:  true,
-			TTY:     true,
+			Command:   command,
+			Container: container,
+			Stdin:     false,
+			Stdout:    true,
+			Stderr:    true,
+			TTY:       true,
 		}, scheme.ParameterCodec)
 
 	exec, err := remotecommand.NewSPDYExecutor(c.K8sRestConfig, "POST", req.URL())
@@ -240,7 +241,6 @@ func (c *DataCollector) QueryCRD(crd crds.Crd, namespace string, ctx context.Con
 	c.K8sRestConfig.NegotiatedSerializer = negotiatedSerializer
 
 	client, err := rest.RESTClientFor(c.K8sRestConfig)
-
 	if err != nil {
 		return nil, err
 	}