fix: add kubernetes resource

Author: Arta Asadi

cloudql/kubernetes/plugin.go

@@ -19,6 +19,7 @@ func Plugin(ctx context.Context) *plugin.Plugin {
 		},
 		DefaultTransform: transform.FromCamel(),
 		TableMap: map[string]*plugin.Table{
+			"k8_resource":                   tableKubernetesResource(ctx),
 			"k8_cluster":                    tableKubernetesCluster(ctx),
 			"k8_cluster_role":               tableKubernetesClusterRole(ctx),
 			"k8_cluster_role_binding":       tableKubernetesClusterRoleBinding(ctx),

cloudql/kubernetes/table_kubernetes_resource.go

@@ -0,0 +1,70 @@
+package kubernetes
+
+import (
+	"context"
+	opengovernance "github.com/opengovern/og-describer-kubernetes/discovery/pkg/es"
+
+	"github.com/turbot/steampipe-plugin-sdk/v5/grpc/proto"
+	"github.com/turbot/steampipe-plugin-sdk/v5/plugin"
+	"github.com/turbot/steampipe-plugin-sdk/v5/plugin/transform"
+)
+
+func tableKubernetesResource(ctx context.Context) *plugin.Table {
+	return &plugin.Table{
+		Name:        "k8_resource",
+		Description: "ClusterRole contains rules that represent a set of permissions.",
+		List: &plugin.ListConfig{
+			Hydrate: opengovernance.ListKubernetesCluster,
+		},
+		Columns: commonGeneralColumns([]*plugin.Column{
+			{
+				Name:        "kind",
+				Type:        proto.ColumnType_STRING,
+				Description: "Resource Kind",
+				Transform:   transform.FromField("Description.Kind"),
+			},
+			{
+				Name:        "object_name",
+				Type:        proto.ColumnType_STRING,
+				Description: "object name.",
+				Transform:   transform.FromField("Description.ObjectName"),
+			},
+			{
+				Name:        "namespace",
+				Type:        proto.ColumnType_STRING,
+				Description: "namespace.",
+				Transform:   transform.FromField("Description.Namespace"),
+			},
+			{
+				Name:        "uid",
+				Type:        proto.ColumnType_STRING,
+				Description: "uid.",
+				Transform:   transform.FromField("Description.UID"),
+			},
+			{
+				Name:        "creation_timestamp",
+				Type:        proto.ColumnType_STRING,
+				Description: "creation timestamp.",
+				Transform:   transform.FromField("Description.CreationTimestamp"),
+			},
+			{
+				Name:        "resource_version",
+				Type:        proto.ColumnType_STRING,
+				Description: "resource version.",
+				Transform:   transform.FromField("Description.ResourceVersion"),
+			},
+			{
+				Name:        "resource_table",
+				Type:        proto.ColumnType_STRING,
+				Description: "creation timestamp.",
+				Transform:   transform.FromField("Description.ResourceTable"),
+			},
+			{
+				Name:        "api_version",
+				Type:        proto.ColumnType_STRING,
+				Description: "creation timestamp.",
+				Transform:   transform.FromField("Description.ApiVersion"),
+			},
+		}),
+	}
+}

discovery/describers/kubernetes.go

@@ -11,6 +11,33 @@ import (
 	"k8s.io/apimachinery/pkg/runtime/schema"
 )
 
+func KubernetesResources(ctx context.Context, client model.Client, extra string, stream *models.StreamSender) ([]models.Resource, error) {
+	var allValues []models.Resource
+
+	resources, err := GetKubernetesResources(client.KubeConfig)
+	if err != nil {
+		return nil, err
+	}
+
+	for _, r := range resources {
+		resource := models.Resource{
+			ID:          r.UID,
+			Name:        r.ObjectName,
+			Description: r,
+		}
+
+		if stream != nil {
+			if err := (*stream)(resource); err != nil {
+				return allValues, fmt.Errorf("error streaming resource: %w", err)
+			}
+		} else {
+			allValues = append(allValues, resource)
+		}
+	}
+
+	return allValues, nil
+}
+
 func KubernetesCluster(ctx context.Context, client model.Client, extra string, stream *models.StreamSender) ([]models.Resource, error) {
 	var allValues []models.Resource
 

discovery/describers/kubernetes_cluster.go

@@ -328,8 +328,6 @@ func DoDiscovery(kubeConfig string) (*model.KubernetesClusterDescription, error)
 
 	kubeconfigPath := "./kubeconfig.yaml"
 
-	fmt.Println("kubeConfig", kubeConfig)
-
 	// Write the string into the file with 0600 permissions
 	err := os.WriteFile(kubeconfigPath, []byte(kubeConfig), 0600)
 	if err != nil {