fix: add kubernetes cluster describer

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{
+			"kubernetes_cluster":                    tableKubernetesCluster(ctx),
 			"kubernetes_cluster_role":               tableKubernetesClusterRole(ctx),
 			"kubernetes_cluster_role_binding":       tableKubernetesClusterRoleBinding(ctx),
 			"kubernetes_config_map":                 tableKubernetesConfigMap(ctx),

cloudql/kubernetes/table_kubernetes_cluster.go

@@ -0,0 +1,52 @@
+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 tableKubernetesCluster(ctx context.Context) *plugin.Table {
+	return &plugin.Table{
+		Name:        "kubernetes_cluster",
+		Description: "ClusterRole contains rules that represent a set of permissions.",
+		List: &plugin.ListConfig{
+			Hydrate: opengovernance.ListKubernetesCluster,
+		},
+		Columns: commonColumns([]*plugin.Column{
+			{
+				Name:        "context_name",
+				Type:        proto.ColumnType_STRING,
+				Description: "Context name of the cluster.",
+				Transform:   transform.FromField("Description.ContextName"),
+			},
+			{
+				Name:        "endpoint",
+				Type:        proto.ColumnType_STRING,
+				Description: "endpoint of the cluster.",
+				Transform:   transform.FromField("Description.Endpoint"),
+			},
+			{
+				Name:        "auth_method",
+				Type:        proto.ColumnType_STRING,
+				Description: "cluster auth method.",
+				Transform:   transform.FromField("Description.AuthMethod"),
+			},
+			{
+				Name:        "tls_server_verification",
+				Type:        proto.ColumnType_BOOL,
+				Description: "endpoint of the cluster.",
+				Transform:   transform.FromField("Description.TLSServerVerification"),
+			},
+			{
+				Name:        "server_version",
+				Type:        proto.ColumnType_STRING,
+				Description: "endpoint of the cluster.",
+				Transform:   transform.FromField("Description.ServerVersion"),
+			},
+		}),
+	}
+}

discovery/describers/kubernetes.go

@@ -10,6 +10,29 @@ import (
 	"k8s.io/apimachinery/pkg/runtime/schema"
 )
 
+func KubernetesCluster(ctx context.Context, client model.Client, extra string, stream *models.StreamSender) ([]models.Resource, error) {
+	var allValues []models.Resource
+
+	cluster, err := DoDiscovery(client.KubeConfig)
+	if err != nil {
+		return nil, err
+	}
+	resource := models.Resource{
+		ID:          fmt.Sprintf("cluster/%s", cluster.ContextName),
+		Name:        cluster.ContextName,
+		Description: cluster,
+	}
+
+	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 KubernetesClusterRole(ctx context.Context, client model.Client, extra string, stream *models.StreamSender) ([]models.Resource, error) {
 	var allValues []models.Resource