Issue 36: Add support for NGF - NGINX Gateway Fabric

* Split jobs in common, nic and ngf specific ones
* Split CRD list into nic and ngf specific ones
* Modified PodExecutor to execute command on a target container

Author: mrajagopal

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,7 +51,9 @@ 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")
 				os.Exit(1)

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,7 @@ func (c *DataCollector) QueryCRD(crd crds.Crd, namespace string, ctx context.Con
 	c.K8sRestConfig.NegotiatedSerializer = negotiatedSerializer
 
 	client, err := rest.RESTClientFor(c.K8sRestConfig)
-
+	c.Logger.Printf("MRAJAGOPAL: %v", err)
 	if err != nil {
 		return nil, err
 	}