feat: aws integration (#967)

* chore: updated deps Signed-off-by: Alex Jones <alexsimonjones@gmail.com> * chore: adding aws types Signed-off-by: Alex Jones <alexsimonjones@gmail.com> * chore: first cut Signed-off-by: Alex Jones <alexsimonjones@gmail.com> * chore: first pass at aws integration with EKS Signed-off-by: Alex Jones <alexsimonjones@gmail.com> * chore: fixed linting Signed-off-by: Alex Jones <alexsimonjones@gmail.com> * chore: updated wording based on PR Signed-off-by: Alex Jones <alexsimonjones@gmail.com> * chore: improved the kubeconfig Signed-off-by: Alex Jones <alexsimonjones@gmail.com> --------- Signed-off-by: Alex Jones <alexsimonjones@gmail.com>
2025-09-16 15:20:38 +00:00 · 2024-02-26 10:16:32 +00:00
parent 6103c96c41
commit a81377f72d
4 changed files with 168 additions and 4 deletions
--- a/pkg/integration/aws/eks.go
+++ b/pkg/integration/aws/eks.go
@@ -0,0 +1,80 @@
+package aws
+
+import (
+	"errors"
+	"github.com/spf13/viper"
+	"os"
+	"path/filepath"
+	"strings"
+
+	"github.com/aws/aws-sdk-go/aws/session"
+	"github.com/aws/aws-sdk-go/service/eks"
+	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
+	"k8s.io/client-go/tools/clientcmd"
+)
+
+type EKSAnalyzer struct {
+	session *session.Session
+}
+
+func (e *EKSAnalyzer) Analyze(analysis common.Analyzer) ([]common.Result, error) {
+	var cr []common.Result = []common.Result{}
+	_ = map[string]common.PreAnalysis{}
+	svc := eks.New(e.session)
+	// Get the name of the current cluster
+	var kubeconfig string
+	kubeconfigFromPath := viper.GetString("kubeconfig")
+	if kubeconfigFromPath != "" {
+		kubeconfig = kubeconfigFromPath
+	} else {
+		kubeconfig = filepath.Join(os.Getenv("HOME"), ".kube", "config")
+	}
+	config, err := clientcmd.NewNonInteractiveDeferredLoadingClientConfig(
+		&clientcmd.ClientConfigLoadingRules{ExplicitPath: kubeconfig},
+		&clientcmd.ConfigOverrides{
+			CurrentContext: "",
+		}).RawConfig()
+	if err != nil {
+		return cr, err
+	}
+	currentConfig := config.CurrentContext
+
+	if !strings.Contains(currentConfig, "eks") {
+		return cr, errors.New("EKS cluster was not detected")
+	}
+
+	input := &eks.ListClustersInput{}
+	result, err := svc.ListClusters(input)
+	if err != nil {
+		return cr, err
+	}
+	for _, cluster := range result.Clusters {
+		// describe the cluster
+		if !strings.Contains(currentConfig, *cluster) {
+			continue
+		}
+		input := &eks.DescribeClusterInput{
+			Name: cluster,
+		}
+		result, err := svc.DescribeCluster(input)
+		if err != nil {
+			return cr, err
+		}
+		if len(result.Cluster.Health.Issues) > 0 {
+			for _, issue := range result.Cluster.Health.Issues {
+				err := make([]common.Failure, 0)
+				err = append(err, common.Failure{
+					Text:          issue.String(),
+					KubernetesDoc: "",
+					Sensitive:     nil,
+				})
+				cr = append(cr, common.Result{
+					Kind:  "EKS",
+					Name:  "AWS/EKS",
+					Error: err,
+				})
+			}
+		}
+	}
+	return cr, nil
+}