chore(main): release 0.3.29 (#1024 )

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
chore: allows an environmental override of the default AWS region and… (#1025 )
2026-03-19 11:33:08 +00:00 · 2024-03-22 10:26:55 +00:00 · 2024-03-22 10:19:11 +00:00 · 2024-03-21 18:13:32 +00:00 · 2024-03-21 11:42:12 +00:00 · 2024-03-21 11:02:19 +00:00
46 changed files with 3486 additions and 633 deletions
--- a/.github/workflows/build_container.yaml
+++ b/.github/workflows/build_container.yaml
@@ -74,10 +74,10 @@ jobs:

      - name: Set up Docker Buildx
        id: buildx
-        uses: docker/setup-buildx-action@f95db51fddba0c2d1ec667646a06c2ce06100226 # v3
+        uses: docker/setup-buildx-action@0d103c3126aa41d772a8362f6aa67afac040f80c # v3

      - name: Build Docker Image
-        uses: docker/build-push-action@4a13e500e55cf31b7a5d59a38ab2040ab0f42f56 # v5
+        uses: docker/build-push-action@af5a7ed5ba88268d5278f7203fb52cd833f66d6e # v5
        with:
          context: .
          platforms: linux/amd64
@@ -126,10 +126,10 @@ jobs:

      - name: Set up Docker Buildx
        id: buildx
-        uses: docker/setup-buildx-action@f95db51fddba0c2d1ec667646a06c2ce06100226 # v3
+        uses: docker/setup-buildx-action@0d103c3126aa41d772a8362f6aa67afac040f80c # v3

      - name: Build Docker Image
-        uses: docker/build-push-action@4a13e500e55cf31b7a5d59a38ab2040ab0f42f56 # v5
+        uses: docker/build-push-action@af5a7ed5ba88268d5278f7203fb52cd833f66d6e # v5
        with:
          context: .
          file: ./container/Dockerfile
--- a/.github/workflows/golangci_lint.yaml
+++ b/.github/workflows/golangci_lint.yaml
@@ -12,9 +12,9 @@ jobs:
        uses: actions/checkout@b4ffde65f46336ab88eb53be808477a3936bae11 # v4

      - name: golangci-lint
-        uses: reviewdog/action-golangci-lint@8e1117c7d327bbfb1eb7ec8dc2d895d13e6e17c3 # v2
+        uses: reviewdog/action-golangci-lint@00311c26a97213f93f2fd3a3524d66762e956ae0 # v2
        with:
          github_token: ${{ secrets.GITHUB_TOKEN }}
          reporter: github-pr-check
-          golangci_lint_flags: "--timeout=120s"
+          golangci_lint_flags: "--timeout=240s"
          level: warning
--- a/.github/workflows/release.yaml
+++ b/.github/workflows/release.yaml
@@ -49,7 +49,7 @@ jobs:
        with:
          go-version: '1.21'
      - name: Download Syft
-        uses: anchore/sbom-action/download-syft@b6a39da80722a2cb0ef5d197531764a89b5d48c3 # v0.15.8
+        uses: anchore/sbom-action/download-syft@9fece9e20048ca9590af301449208b2b8861333b # v0.15.9
      - name: Run GoReleaser
        uses: goreleaser/goreleaser-action@7ec5c2b0c6cdda6e8bbb49444bc797dd33d74dd8 # v5
        with:
@@ -80,7 +80,7 @@ jobs:

      - name: Set up Docker Buildx
        id: buildx
-        uses: docker/setup-buildx-action@f95db51fddba0c2d1ec667646a06c2ce06100226 # v3
+        uses: docker/setup-buildx-action@0d103c3126aa41d772a8362f6aa67afac040f80c # v3

      - name: Login to GitHub Container Registry
        uses: docker/login-action@343f7c4344506bcbf9b4de18042ae17996df046d # v3
@@ -90,7 +90,7 @@ jobs:
          password: ${{ secrets.GITHUB_TOKEN }}

      - name: Build Docker Image
-        uses: docker/build-push-action@4a13e500e55cf31b7a5d59a38ab2040ab0f42f56 # v5
+        uses: docker/build-push-action@af5a7ed5ba88268d5278f7203fb52cd833f66d6e # v5
        with:
          context: .
          file: ./container/Dockerfile
@@ -104,7 +104,7 @@ jobs:
          cache-to: type=gha,scope=${{ github.ref_name }}-${{ env.IMAGE_TAG }}

      - name: Generate SBOM
-        uses: anchore/sbom-action@b6a39da80722a2cb0ef5d197531764a89b5d48c3 # v0.15.8
+        uses: anchore/sbom-action@9fece9e20048ca9590af301449208b2b8861333b # v0.15.9
        with:
          image: ${{ env.IMAGE_TAG }}
          artifact-name: sbom-${{ env.IMAGE_NAME }}
--- a/.github/workflows/test.yaml
+++ b/.github/workflows/test.yaml
@@ -9,11 +9,10 @@ on:
      - main

 env:
-    GO_VERSION: "~1.21"
+  GO_VERSION: "~1.21"

 jobs:
  build:
-
    runs-on: ubuntu-latest
    steps:
      - uses: actions/checkout@b4ffde65f46336ab88eb53be808477a3936bae11 # v4
@@ -24,4 +23,8 @@ jobs:
          go-version: ${{ env.GO_VERSION }}

      - name: Run test
-        run: go test ./... 
+        run: go test ./... -coverprofile=coverage.txt
+      - name: Upload coverage to Codecov
+        uses: codecov/codecov-action@v3
+        env:
+          CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}
--- a/.release-please-manifest.json
+++ b/.release-please-manifest.json
@@ -1 +1 @@
-{".":"0.3.27"}
+{".":"0.3.29"}
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,5 +1,65 @@
 # Changelog

+## [0.3.29](https://github.com/k8sgpt-ai/k8sgpt/compare/v0.3.28...v0.3.29) (2024-03-22)
+
+
+### Features
+
+* codecov ([#1023](https://github.com/k8sgpt-ai/k8sgpt/issues/1023)) ([fe81d16](https://github.com/k8sgpt-ai/k8sgpt/commit/fe81d16f756e5ea9db909e42e6caf1e17e040f86))
+
+
+### Other
+
+* allows an environmental override of the default AWS region and… ([#1025](https://github.com/k8sgpt-ai/k8sgpt/issues/1025)) ([8f8f5c6](https://github.com/k8sgpt-ai/k8sgpt/commit/8f8f5c6df7fbcd08ee48d91a4f2e011a3e69e4ac))
+
+## [0.3.28](https://github.com/k8sgpt-ai/k8sgpt/compare/v0.3.27...v0.3.28) (2024-03-14)
+
+
+### Features
+
+* add Google Vertex AI as provider to utilize gemini via GCP ([#984](https://github.com/k8sgpt-ai/k8sgpt/issues/984)) ([55ac0b2](https://github.com/k8sgpt-ai/k8sgpt/commit/55ac0b2129a438661a0253251f546db6b59f2b92))
+* add proxysettings for azureopenai and openai ([#987](https://github.com/k8sgpt-ai/k8sgpt/issues/987)) ([307710e](https://github.com/k8sgpt-ai/k8sgpt/commit/307710eddc1c3f96f40a674f7dda786510e9c4cc))
+* aws integration ([#967](https://github.com/k8sgpt-ai/k8sgpt/issues/967)) ([a81377f](https://github.com/k8sgpt-ai/k8sgpt/commit/a81377f72db7f322e0afbb6d613c2bfffecf8080))
+* enable Rest api using grpc-gateway ([#834](https://github.com/k8sgpt-ai/k8sgpt/issues/834)) ([f2138c7](https://github.com/k8sgpt-ai/k8sgpt/commit/f2138c71017b391625eebdfb4c5708c824824f69))
+
+
+### Bug Fixes
+
+* analyze command default backend bug ([#966](https://github.com/k8sgpt-ai/k8sgpt/issues/966)) ([aab8d77](https://github.com/k8sgpt-ai/k8sgpt/commit/aab8d77febdd4b42ff74aafbb2ada27745c04ae1))
+* **deps:** update module cloud.google.com/go/storage to v1.38.0 ([#950](https://github.com/k8sgpt-ai/k8sgpt/issues/950)) ([6207c70](https://github.com/k8sgpt-ai/k8sgpt/commit/6207c70c51d2885c4590c255c8f78e7ee2009034))
+* **deps:** update module github.com/aws/aws-sdk-go to v1.50.20 ([#930](https://github.com/k8sgpt-ai/k8sgpt/issues/930)) ([3f0356b](https://github.com/k8sgpt-ai/k8sgpt/commit/3f0356be662c32d82ce4f3db05f859477823717d))
+* **deps:** update module github.com/aws/aws-sdk-go to v1.50.21 ([#970](https://github.com/k8sgpt-ai/k8sgpt/issues/970)) ([00c91f0](https://github.com/k8sgpt-ai/k8sgpt/commit/00c91f05a62b2c8b2d756b58b95279195ff38d3d))
+* **deps:** update module github.com/aws/aws-sdk-go to v1.50.22 ([#971](https://github.com/k8sgpt-ai/k8sgpt/issues/971)) ([6ac815c](https://github.com/k8sgpt-ai/k8sgpt/commit/6ac815c10fb073f4251e338ab22e247625f21406))
+* **deps:** update module github.com/aws/aws-sdk-go to v1.50.34 ([#974](https://github.com/k8sgpt-ai/k8sgpt/issues/974)) ([425f33b](https://github.com/k8sgpt-ai/k8sgpt/commit/425f33bb2ddf8cdaff079b097d6956f675c89b0e))
+* **deps:** update module github.com/azure/azure-sdk-for-go/sdk/storage/azblob to v1.3.1 ([#992](https://github.com/k8sgpt-ai/k8sgpt/issues/992)) ([85f18dd](https://github.com/k8sgpt-ai/k8sgpt/commit/85f18dde1f820fe2413cc6b3109e67b7a010142c))
+* **deps:** update module github.com/google/generative-ai-go to v0.8.0 ([#965](https://github.com/k8sgpt-ai/k8sgpt/issues/965)) ([248260e](https://github.com/k8sgpt-ai/k8sgpt/commit/248260e081327de9f9d1d2c851efab2b4a3e7ede))
+* **deps:** update module github.com/prometheus/client_golang to v1.19.0 ([#989](https://github.com/k8sgpt-ai/k8sgpt/issues/989)) ([4065fae](https://github.com/k8sgpt-ai/k8sgpt/commit/4065faef13691f9cf1f50696c62d3b30b0933b4b))
+* **deps:** update module github.com/sashabaranov/go-openai to v1.19.4 ([#963](https://github.com/k8sgpt-ai/k8sgpt/issues/963)) ([8b0b61e](https://github.com/k8sgpt-ai/k8sgpt/commit/8b0b61e596f790b9558a5e3d1f634a5ee1c6cb0c))
+* **deps:** update module github.com/sashabaranov/go-openai to v1.20.0 ([#977](https://github.com/k8sgpt-ai/k8sgpt/issues/977)) ([e07822c](https://github.com/k8sgpt-ai/k8sgpt/commit/e07822c10bff5dbd91f4da592914c25538353d6b))
+* **deps:** update module github.com/sashabaranov/go-openai to v1.20.1 ([#986](https://github.com/k8sgpt-ai/k8sgpt/issues/986)) ([88a7907](https://github.com/k8sgpt-ai/k8sgpt/commit/88a7907db4700c241e9aa109bc3d8604a8186f87))
+* **deps:** update module github.com/sashabaranov/go-openai to v1.20.2 ([#991](https://github.com/k8sgpt-ai/k8sgpt/issues/991)) ([d2754d3](https://github.com/k8sgpt-ai/k8sgpt/commit/d2754d320fb1f285f93fdced2b8469280bd47fd2))
+* **deps:** update module github.com/schollz/progressbar/v3 to v3.14.2 ([#983](https://github.com/k8sgpt-ai/k8sgpt/issues/983)) ([af3732a](https://github.com/k8sgpt-ai/k8sgpt/commit/af3732ad067b809c54c5f08f6cf5a7a519b452d7))
+* **deps:** update module github.com/stretchr/testify to v1.9.0 ([#999](https://github.com/k8sgpt-ai/k8sgpt/issues/999)) ([1491e67](https://github.com/k8sgpt-ai/k8sgpt/commit/1491e675673dcc13ccf6ac1778113762542e8cbc))
+* **deps:** update module go.uber.org/zap to v1.27.0 ([#972](https://github.com/k8sgpt-ai/k8sgpt/issues/972)) ([8f00218](https://github.com/k8sgpt-ai/k8sgpt/commit/8f002180901c8bf7e6b1a5451dd97ef566260b0f))
+* **deps:** update module google.golang.org/api to v0.165.0 ([#959](https://github.com/k8sgpt-ai/k8sgpt/issues/959)) ([cc99bd5](https://github.com/k8sgpt-ai/k8sgpt/commit/cc99bd51f05db4e87f806ac58ee1cb7a83b25e4d))
+* **deps:** update module google.golang.org/api to v0.167.0 ([#973](https://github.com/k8sgpt-ai/k8sgpt/issues/973)) ([6103c96](https://github.com/k8sgpt-ai/k8sgpt/commit/6103c96c41e10e2fe13d285ff15a36bf2fbeb5c2))
+* **deps:** update module google.golang.org/grpc to v1.62.0 ([#975](https://github.com/k8sgpt-ai/k8sgpt/issues/975)) ([97446aa](https://github.com/k8sgpt-ai/k8sgpt/commit/97446aae079824d6556416314c0a27514088a667))
+* **deps:** update module gopkg.in/yaml.v2 to v3 ([#957](https://github.com/k8sgpt-ai/k8sgpt/issues/957)) ([f929e7f](https://github.com/k8sgpt-ai/k8sgpt/commit/f929e7feea5931ddec77af49dd08937aca85fd49))
+* **deps:** update module gopkg.in/yaml.v2 to v3 ([#979](https://github.com/k8sgpt-ai/k8sgpt/issues/979)) ([35f5185](https://github.com/k8sgpt-ai/k8sgpt/commit/35f51859140c78ce953443afcc27f77230287809))
+* **deps:** update module gopkg.in/yaml.v2 to v3 ([#980](https://github.com/k8sgpt-ai/k8sgpt/issues/980)) ([334a86a](https://github.com/k8sgpt-ai/k8sgpt/commit/334a86aaf40e5421929cf380191841db064d9bf7))
+* log analyzer failed with multiple containers in the pod ([#920](https://github.com/k8sgpt-ai/k8sgpt/issues/920)) ([98286a9](https://github.com/k8sgpt-ai/k8sgpt/commit/98286a965e4c4c680deeb43d3397b51089968366))
+* set result name and namespace to trivy vulnreport and configaudi… ([#869](https://github.com/k8sgpt-ai/k8sgpt/issues/869)) ([a3cd7e6](https://github.com/k8sgpt-ai/k8sgpt/commit/a3cd7e6385365a1d190a9e8439311cb9d5eeda56))
+* shorthand for the http flag in serve command ([#969](https://github.com/k8sgpt-ai/k8sgpt/issues/969)) ([f55f837](https://github.com/k8sgpt-ai/k8sgpt/commit/f55f8370ebf0db6db629641337cd78ad7f120865))
+
+
+### Other
+
+* attempt to group renovate deps ([#1007](https://github.com/k8sgpt-ai/k8sgpt/issues/1007)) ([adf4f17](https://github.com/k8sgpt-ai/k8sgpt/commit/adf4f17085672fd5ae78dad4f8ac1d887029836d))
+* **deps:** update anchore/sbom-action action to v0.15.9 ([#1004](https://github.com/k8sgpt-ai/k8sgpt/issues/1004)) ([b05b6a3](https://github.com/k8sgpt-ai/k8sgpt/commit/b05b6a38ed4a9fc017f9dcb52cff8a332c11056d))
+* **deps:** update docker/build-push-action digest to af5a7ed ([#1003](https://github.com/k8sgpt-ai/k8sgpt/issues/1003)) ([b58b719](https://github.com/k8sgpt-ai/k8sgpt/commit/b58b7191af2fe082d94d46ef6a2784c1ea322340))
+* **deps:** update docker/setup-buildx-action digest to 0d103c3 ([#988](https://github.com/k8sgpt-ai/k8sgpt/issues/988)) ([f24bcd8](https://github.com/k8sgpt-ai/k8sgpt/commit/f24bcd88b6a915798897b49a562b86265a9b524c))
+* **deps:** update reviewdog/action-golangci-lint digest to 00311c2 ([#1002](https://github.com/k8sgpt-ai/k8sgpt/issues/1002)) ([4ec143a](https://github.com/k8sgpt-ai/k8sgpt/commit/4ec143ab772ca4dc3072c248e95da8f7c0a2974b))
+
 ## [0.3.27](https://github.com/k8sgpt-ai/k8sgpt/compare/v0.3.26...v0.3.27) (2024-02-15)


--- a/README.md
+++ b/README.md
@@ -19,7 +19,7 @@

 It has SRE experience codified into its analyzers and helps to pull out the most relevant information to enrich it with AI.

-_Out of the box integration with OpenAI, Azure, Cohere, Amazon Bedrock and local models._
+_Out of the box integration with OpenAI, Azure, Cohere, Amazon Bedrock, Google Gemini and local models._

 <a href="https://www.producthunt.com/posts/k8sgpt?utm_source=badge-featured&utm_medium=badge&utm_souce=badge-k8sgpt" target="_blank"><img src="https://api.producthunt.com/widgets/embed-image/v1/featured.svg?post_id=389489&theme=light" alt="K8sGPT - K8sGPT&#0032;gives&#0032;Kubernetes&#0032;Superpowers&#0032;to&#0032;everyone | Product Hunt" style="width: 250px; height: 54px;" width="250" height="54" /></a>

@@ -41,7 +41,7 @@ brew install k8sgpt
  **32 bit:**
  <!---x-release-please-start-version-->
  ```
-  curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.3.27/k8sgpt_386.rpm
+  curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.3.29/k8sgpt_386.rpm
  sudo rpm -ivh k8sgpt_386.rpm
  ```
  <!---x-release-please-end-->
@@ -50,7 +50,7 @@ brew install k8sgpt

  <!---x-release-please-start-version-->
  ```
-  curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.3.27/k8sgpt_amd64.rpm
+  curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.3.29/k8sgpt_amd64.rpm
  sudo rpm -ivh -i k8sgpt_amd64.rpm
  ```
  <!---x-release-please-end-->
@@ -62,7 +62,7 @@ brew install k8sgpt
  **32 bit:**
  <!---x-release-please-start-version-->
  ```
-  curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.3.27/k8sgpt_386.deb
+  curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.3.29/k8sgpt_386.deb
  sudo dpkg -i k8sgpt_386.deb
  ```
  <!---x-release-please-end-->
@@ -70,7 +70,7 @@ brew install k8sgpt

  <!---x-release-please-start-version-->
  ```
-  curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.3.27/k8sgpt_amd64.deb
+  curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.3.29/k8sgpt_amd64.deb
  sudo dpkg -i k8sgpt_amd64.deb
  ```
  <!---x-release-please-end-->
@@ -83,14 +83,14 @@ brew install k8sgpt
  **32 bit:**
  <!---x-release-please-start-version-->
  ```
-  curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.3.27/k8sgpt_386.apk
+  curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.3.29/k8sgpt_386.apk
  apk add k8sgpt_386.apk
  ```
  <!---x-release-please-end-->
  **64 bit:**
  <!---x-release-please-start-version-->
  ```
-  curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.3.27/k8sgpt_amd64.apk
+  curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.3.29/k8sgpt_amd64.apk
  apk add k8sgpt_amd64.apk
  ```
  <!---x-release-please-end-->x
@@ -314,6 +314,7 @@ Unused:
 > google
 > huggingface
 > noopai
+> googlevertexai
 ```

 For detailed documentation on how to configure and use each provider see [here](https://docs.k8sgpt.ai/reference/providers/backend/).
--- a/cmd/analyze/analyze.go
+++ b/cmd/analyze/analyze.go
@@ -60,6 +60,7 @@ var AnalyzeCmd = &cobra.Command{
 			withDoc,
 			interactiveMode,
 		)
+
 		if err != nil {
 			color.Red("Error: %v", err)
 			os.Exit(1)
@@ -124,7 +125,7 @@ func init() {
 	// explain flag
 	AnalyzeCmd.Flags().BoolVarP(&explain, "explain", "e", false, "Explain the problem to me")
 	// add flag for backend
-	AnalyzeCmd.Flags().StringVarP(&backend, "backend", "b", "openai", "Backend AI provider")
+	AnalyzeCmd.Flags().StringVarP(&backend, "backend", "b", "", "Backend AI provider")
 	// output as json
 	AnalyzeCmd.Flags().StringVarP(&output, "output", "o", "text", "Output format (text, json)")
 	// add language options for output
--- a/cmd/auth/add.go
+++ b/cmd/auth/add.go
@@ -45,6 +45,9 @@ var addCmd = &cobra.Command{
 			_ = cmd.MarkFlagRequired("endpointname")
 			_ = cmd.MarkFlagRequired("providerRegion")
 		}
+		if strings.ToLower(backend) == "amazonbedrock" {
+			_ = cmd.MarkFlagRequired("providerRegion")
+		}
 	},
 	Run: func(cmd *cobra.Command, args []string) {

@@ -119,6 +122,7 @@ var addCmd = &cobra.Command{
 			Engine:         engine,
 			Temperature:    temperature,
 			ProviderRegion: providerRegion,
+			ProviderId:     providerId,
 			TopP:           topP,
 			MaxTokens:      maxTokens,
 		}
@@ -159,5 +163,7 @@ func init() {
 	// add flag for azure open ai engine/deployment name
 	addCmd.Flags().StringVarP(&engine, "engine", "e", "", "Azure AI deployment name (only for azureopenai backend)")
 	//add flag for amazonbedrock region name
-	addCmd.Flags().StringVarP(&providerRegion, "providerRegion", "r", "", "Provider Region name (only for amazonbedrock backend)")
+	addCmd.Flags().StringVarP(&providerRegion, "providerRegion", "r", "", "Provider Region name (only for amazonbedrock, googlevertexai backend)")
+	//add flag for vertexAI Project ID
+	addCmd.Flags().StringVarP(&providerId, "providerId", "i", "", "Provider specific ID for e.g. project (only for googlevertexai backend)")
 }
--- a/cmd/auth/auth.go
+++ b/cmd/auth/auth.go
@@ -27,6 +27,7 @@ var (
 	engine         string
 	temperature    float32
 	providerRegion string
+	providerId     string
 	topP           float32
 	maxTokens      int
 )
--- a/cmd/integration/activate.go
+++ b/cmd/integration/activate.go
@@ -21,9 +21,7 @@ import (
 	"github.com/spf13/viper"
 )

-var (
-	skipInstall bool
-)
+var skipInstall bool

 // activateCmd represents the activate command
 var activateCmd = &cobra.Command{
@@ -56,5 +54,4 @@ var activateCmd = &cobra.Command{
 func init() {
 	IntegrationCmd.AddCommand(activateCmd)
 	activateCmd.Flags().BoolVarP(&skipInstall, "no-install", "s", false, "Only activate the integration filter without installing the filter (for example, if that filter plugin is already deployed in cluster, we do not need to re-install it again)")
-
 }
--- a/cmd/serve/serve.go
+++ b/cmd/serve/serve.go
@@ -33,6 +33,7 @@ var (
 	port        string
 	metricsPort string
 	backend     string
+	enableHttp  bool
 )

 var ServeCmd = &cobra.Command{
@@ -72,6 +73,7 @@ var ServeCmd = &cobra.Command{
 			model := os.Getenv("K8SGPT_MODEL")
 			baseURL := os.Getenv("K8SGPT_BASEURL")
 			engine := os.Getenv("K8SGPT_ENGINE")
+			proxyEndpoint := os.Getenv("K8SGPT_PROXY_ENDPOINT")
 			// If the envs are set, allocate in place to the aiProvider
 			// else exit with error
 			envIsSet := backend != "" || password != "" || model != ""
@@ -82,6 +84,7 @@ var ServeCmd = &cobra.Command{
 					Model:       model,
 					BaseURL:     baseURL,
 					Engine:      engine,
+					ProxyEndpoint: proxyEndpoint,
 					Temperature: temperature(),
 				}

@@ -131,6 +134,7 @@ var ServeCmd = &cobra.Command{
 			Backend:     aiProvider.Name,
 			Port:        port,
 			MetricsPort: metricsPort,
+			EnableHttp:  enableHttp,
 			Token:       aiProvider.Password,
 			Logger:      logger,
 		}
@@ -158,4 +162,5 @@ func init() {
 	ServeCmd.Flags().StringVarP(&port, "port", "p", "8080", "Port to run the server on")
 	ServeCmd.Flags().StringVarP(&metricsPort, "metrics-port", "", "8081", "Port to run the metrics-server on")
 	ServeCmd.Flags().StringVarP(&backend, "backend", "b", "openai", "Backend AI provider")
+	ServeCmd.Flags().BoolVarP(&enableHttp, "http", "", false, "Enable REST/http using gppc-gateway")
 }
--- a/go.mod
+++ b/go.mod
@@ -7,11 +7,11 @@ require (
 	github.com/fatih/color v1.16.0
 	github.com/magiconair/properties v1.8.7
 	github.com/mittwald/go-helm-client v0.12.5
-	github.com/sashabaranov/go-openai v1.19.3
-	github.com/schollz/progressbar/v3 v3.14.1
+	github.com/sashabaranov/go-openai v1.20.2
+	github.com/schollz/progressbar/v3 v3.14.2
 	github.com/spf13/cobra v1.8.0
 	github.com/spf13/viper v1.18.2
-	github.com/stretchr/testify v1.8.4
+	github.com/stretchr/testify v1.9.0
 	golang.org/x/term v0.17.0
 	helm.sh/helm/v3 v3.13.3
 	k8s.io/api v0.28.4
@@ -24,19 +24,21 @@ require (
 require github.com/adrg/xdg v0.4.0

 require (
+	buf.build/gen/go/k8sgpt-ai/k8sgpt/grpc-ecosystem/gateway/v2 v2.19.1-20240213144542-6e830f3fdf19.1
 	buf.build/gen/go/k8sgpt-ai/k8sgpt/grpc/go v1.3.0-20240213144542-6e830f3fdf19.2
 	buf.build/gen/go/k8sgpt-ai/k8sgpt/protocolbuffers/go v1.32.0-20240213144542-6e830f3fdf19.1
-	cloud.google.com/go/storage v1.37.0
+	cloud.google.com/go/storage v1.38.0
 	github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.5.1
-	github.com/Azure/azure-sdk-for-go/sdk/storage/azblob v1.3.0
-	github.com/aws/aws-sdk-go v1.50.2
+	github.com/Azure/azure-sdk-for-go/sdk/storage/azblob v1.3.1
+	github.com/aws/aws-sdk-go v1.50.34
 	github.com/cohere-ai/cohere-go v0.2.0
-	github.com/google/generative-ai-go v0.7.0
+	github.com/google/generative-ai-go v0.8.0
+	github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.1
 	github.com/hupe1980/go-huggingface v0.0.15
 	github.com/olekukonko/tablewriter v0.0.5
 	github.com/prometheus/prometheus v0.49.1
 	github.com/pterm/pterm v0.12.79
-	google.golang.org/api v0.164.0
+	google.golang.org/api v0.167.0
 	gopkg.in/yaml.v2 v2.4.0
 	sigs.k8s.io/controller-runtime v0.16.3
 	sigs.k8s.io/gateway-api v1.0.0
@@ -48,10 +50,12 @@ require (
 	atomicgo.dev/schedule v0.1.0 // indirect
 	cloud.google.com/go v0.112.0 // indirect
 	cloud.google.com/go/ai v0.3.0 // indirect
-	cloud.google.com/go/compute v1.23.3 // indirect
+	cloud.google.com/go/aiplatform v1.59.0 // indirect
+	cloud.google.com/go/compute v1.24.0 // indirect
 	cloud.google.com/go/compute/metadata v0.2.3 // indirect
-	cloud.google.com/go/iam v1.1.5 // indirect
-	cloud.google.com/go/longrunning v0.5.4 // indirect
+	cloud.google.com/go/iam v1.1.6 // indirect
+	cloud.google.com/go/longrunning v0.5.5 // indirect
+	cloud.google.com/go/vertexai v0.7.1 // indirect
 	github.com/Azure/azure-sdk-for-go/sdk/azcore v1.9.2 // indirect
 	github.com/Azure/azure-sdk-for-go/sdk/internal v1.5.2 // indirect
 	github.com/AzureAD/microsoft-authentication-library-for-go v1.2.1 // indirect
@@ -72,14 +76,13 @@ require (
 	github.com/google/gnostic-models v0.6.9-0.20230804172637-c7be7c783f49 // indirect
 	github.com/google/s2a-go v0.1.7 // indirect
 	github.com/googleapis/enterprise-certificate-proxy v0.3.2 // indirect
-	github.com/googleapis/gax-go/v2 v2.12.0 // indirect
+	github.com/googleapis/gax-go/v2 v2.12.1 // indirect
 	github.com/gookit/color v1.5.4 // indirect
 	github.com/grafana/regexp v0.0.0-20221122212121-6b5c0a4cb7fd // indirect
 	github.com/jmespath/go-jmespath v0.4.0 // indirect
 	github.com/jpillora/backoff v1.0.0 // indirect
 	github.com/kylelemons/godebug v1.1.0 // indirect
 	github.com/lithammer/fuzzysearch v1.1.8 // indirect
-	github.com/matttproud/golang_protobuf_extensions/v2 v2.0.0 // indirect
 	github.com/mwitkow/go-conntrack v0.0.0-20190716064945-2f068394615f // indirect
 	github.com/pkg/browser v0.0.0-20240102092130-5ac0b6a4141c // indirect
 	github.com/prometheus/common/sigv4 v0.1.0 // indirect
@@ -88,12 +91,12 @@ require (
 	github.com/sourcegraph/conc v0.3.0 // indirect
 	github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e // indirect
 	go.opencensus.io v0.24.0 // indirect
-	go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.47.0 // indirect
-	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.47.0 // indirect
+	go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.48.0 // indirect
+	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.48.0 // indirect
 	go.opentelemetry.io/otel/metric v1.23.0 // indirect
-	google.golang.org/genproto v0.0.0-20240125205218-1f4bbc51befe // indirect
-	google.golang.org/genproto/googleapis/api v0.0.0-20240125205218-1f4bbc51befe // indirect
-	google.golang.org/genproto/googleapis/rpc v0.0.0-20240205150955-31a09d347014 // indirect
+	google.golang.org/genproto v0.0.0-20240205150955-31a09d347014 // indirect
+	google.golang.org/genproto/googleapis/api v0.0.0-20240205150955-31a09d347014 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20240213162025-012b6fc9bca9 // indirect
 	gopkg.in/evanphx/json-patch.v5 v5.7.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )
@@ -189,11 +192,11 @@ require (
 	github.com/peterbourgon/diskv v2.0.1+incompatible // indirect
 	github.com/pkg/errors v0.9.1 // indirect
 	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
-	github.com/prometheus/client_golang v1.18.0
+	github.com/prometheus/client_golang v1.19.0
 	github.com/prometheus/client_model v0.5.0 // indirect
-	github.com/prometheus/common v0.45.0 // indirect
+	github.com/prometheus/common v0.48.0 // indirect
 	github.com/prometheus/procfs v0.12.0 // indirect
-	github.com/rivo/uniseg v0.4.4 // indirect
+	github.com/rivo/uniseg v0.4.7 // indirect
 	github.com/robfig/cron/v3 v3.0.1
 	github.com/rubenv/sql-migrate v1.5.2 // indirect
 	github.com/russross/blackfriday/v2 v2.1.0 // indirect
@@ -213,10 +216,10 @@ require (
 	go.opentelemetry.io/otel/trace v1.23.0 // indirect
 	go.starlark.net v0.0.0-20231016134836-22325403fcb3 // indirect
 	go.uber.org/multierr v1.11.0 // indirect
-	go.uber.org/zap v1.26.0
+	go.uber.org/zap v1.27.0
 	golang.org/x/crypto v0.19.0 // indirect
 	golang.org/x/exp v0.0.0-20231206192017-f3f8817b8deb // indirect
-	golang.org/x/net v0.21.0 // indirect
+	golang.org/x/net v0.21.0
 	golang.org/x/oauth2 v0.17.0 // indirect
 	golang.org/x/sync v0.6.0 // indirect
 	golang.org/x/sys v0.17.0 // indirect
@@ -224,7 +227,7 @@ require (
 	golang.org/x/time v0.5.0 // indirect
 	golang.org/x/xerrors v0.0.0-20231012003039-104605ab7028 // indirect
 	google.golang.org/appengine v1.6.8 // indirect
-	google.golang.org/grpc v1.61.1
+	google.golang.org/grpc v1.62.0
 	google.golang.org/protobuf v1.32.0 // indirect
 	gopkg.in/inf.v0 v0.9.1 // indirect
 	gopkg.in/ini.v1 v1.67.0 // indirect
--- a/go.sum
+++ b/go.sum
--- a/pkg/ai/amazonbedrock.go
+++ b/pkg/ai/amazonbedrock.go
@@ -4,6 +4,7 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
+	"os"

 	"github.com/aws/aws-sdk-go/aws"
 	"github.com/aws/aws-sdk-go/aws/session"
@@ -76,6 +77,9 @@ func GetModelOrDefault(model string) string {
 // GetModelOrDefault check config region
 func GetRegionOrDefault(region string) string {

+	if os.Getenv("AWS_DEFAULT_REGION") != "" {
+		region = os.Getenv("AWS_DEFAULT_REGION")
+	}
 	// Check if the provided model is in the list
 	for _, m := range BEDROCKER_SUPPORTED_REGION {
 		if m == region {
--- a/pkg/ai/azureopenai.go
+++ b/pkg/ai/azureopenai.go
@@ -3,6 +3,8 @@ package ai
 import (
 	"context"
 	"errors"
+	"net/http"
+	"net/url"

 	"github.com/sashabaranov/go-openai"
 )
@@ -21,6 +23,7 @@ func (c *AzureAIClient) Configure(config IAIConfig) error {
 	token := config.GetPassword()
 	baseURL := config.GetBaseURL()
 	engine := config.GetEngine()
+	proxyEndpoint := config.GetProxyEndpoint()
 	defaultConfig := openai.DefaultAzureConfig(token, baseURL)

 	defaultConfig.AzureModelMapperFunc = func(model string) string {
@@ -31,6 +34,20 @@ func (c *AzureAIClient) Configure(config IAIConfig) error {
 		return azureModelMapping[model]

 	}
+	
+	if proxyEndpoint != "" {
+		proxyUrl, err := url.Parse(proxyEndpoint)
+		if err != nil {
+			return err
+		}
+		transport := &http.Transport{
+			Proxy: http.ProxyURL(proxyUrl),
+		}
+
+		defaultConfig.HTTPClient = &http.Client{
+			Transport: transport,
+		}
+	}
 	client := openai.NewClientWithConfig(defaultConfig)
 	if client == nil {
 		return errors.New("error creating Azure OpenAI client")
--- a/pkg/ai/googlevertexai.go
+++ b/pkg/ai/googlevertexai.go
@@ -0,0 +1,178 @@
+/*
+Copyright 2023 The K8sGPT Authors.
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+    http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package ai
+
+import (
+	"context"
+	"errors"
+	"fmt"
+
+	"cloud.google.com/go/vertexai/genai"
+	"github.com/fatih/color"
+)
+
+const googleVertexAIClientName = "googlevertexai"
+
+type GoogleVertexAIClient struct {
+	client *genai.Client
+
+	model       string
+	temperature float32
+	topP        float32
+	maxTokens   int
+}
+
+// Vertex AI Gemini supported Regions
+// https://cloud.google.com/vertex-ai/docs/generative-ai/model-reference/gemini
+const VERTEXAI_DEFAULT_REGION = "us-central1" // default use us-east-1 region
+
+const (
+	US_Central_1             = "us-central1"
+	US_West_4                = "us-west4"
+	North_America_Northeast1 = "northamerica-northeast1"
+	US_East_4                = "us-east4"
+	US_West_1                = "us-west1"
+	Asia_Northeast_3         = "asia-northeast3"
+	Asia_Southeast_1         = "asia-southeast1"
+	Asia_Northeast_1         = "asia-northeast1"
+)
+
+var VERTEXAI_SUPPORTED_REGION = []string{
+	US_Central_1,
+	US_West_4,
+	North_America_Northeast1,
+	US_East_4,
+	US_West_1,
+	Asia_Northeast_3,
+	Asia_Southeast_1,
+	Asia_Northeast_1,
+}
+
+const (
+	ModelGeminiProV1 = "gemini-1.0-pro-001"
+)
+
+var VERTEXAI_MODELS = []string{
+	ModelGeminiProV1,
+}
+
+// GetModelOrDefault check config model
+func GetVertexAIModelOrDefault(model string) string {
+
+	// Check if the provided model is in the list
+	for _, m := range VERTEXAI_MODELS {
+		if m == model {
+			return model // Return the provided model
+		}
+	}
+
+	// Return the default model if the provided model is not in the list
+	return VERTEXAI_MODELS[0]
+}
+
+// GetModelOrDefault check config region
+func GetVertexAIRegionOrDefault(region string) string {
+
+	// Check if the provided model is in the list
+	for _, m := range VERTEXAI_SUPPORTED_REGION {
+		if m == region {
+			return region // Return the provided model
+		}
+	}
+
+	// Return the default model if the provided model is not in the list
+	return VERTEXAI_DEFAULT_REGION
+}
+
+func (g *GoogleVertexAIClient) Configure(config IAIConfig) error {
+	ctx := context.Background()
+
+	// Currently you can access VertexAI either by being authenticated via OAuth or Bearer token so we need to consider both
+	projectId := config.GetProviderId()
+	region := GetVertexAIRegionOrDefault(config.GetProviderRegion())
+
+	client, err := genai.NewClient(ctx, projectId, region)
+	if err != nil {
+		return fmt.Errorf("creating genai Google SDK client: %w", err)
+	}
+
+	g.client = client
+	g.model = GetVertexAIModelOrDefault(config.GetModel())
+	g.temperature = config.GetTemperature()
+	g.topP = config.GetTopP()
+	g.maxTokens = config.GetMaxTokens()
+
+	return nil
+}
+
+func (g *GoogleVertexAIClient) GetCompletion(ctx context.Context, prompt string) (string, error) {
+
+	model := g.client.GenerativeModel(g.model)
+	model.SetTemperature(g.temperature)
+	model.SetTopP(g.topP)
+	model.SetMaxOutputTokens(int32(g.maxTokens))
+
+	// Google AI SDK is capable of different inputs than just text, for now set explicit text prompt type.
+	// Similarly, we could stream the response. For now k8sgpt does not support streaming.
+	resp, err := model.GenerateContent(ctx, genai.Text(prompt))
+	if err != nil {
+		return "", err
+	}
+
+	if len(resp.Candidates) == 0 {
+		if resp.PromptFeedback.BlockReason > 0 {
+			for _, r := range resp.PromptFeedback.SafetyRatings {
+				if !r.Blocked {
+					continue
+				}
+				return "", fmt.Errorf("complection blocked due to %v with probability %v", r.Category.String(), r.Probability.String())
+			}
+		}
+		return "", errors.New("no complection returned; unknown reason")
+	}
+
+	// Format output.
+	// TODO(bwplotka): Provider richer output in certain cases e.g. suddenly finished
+	// completion based on finish reasons or safety rankings.
+	got := resp.Candidates[0]
+	var output string
+	for _, part := range got.Content.Parts {
+		switch o := part.(type) {
+		case genai.Text:
+			output += string(o)
+			output += "\n"
+		default:
+			color.Yellow("found unsupported AI response part of type %T; ignoring", part)
+		}
+	}
+
+	if got.CitationMetadata != nil && len(got.CitationMetadata.Citations) > 0 {
+		output += "Citations:\n"
+		for _, source := range got.CitationMetadata.Citations {
+			// TODO(bwplotka): Give details around what exactly words could be attributed to the citation.
+			output += fmt.Sprintf("* %s, %s\n", source.URI, source.License)
+		}
+	}
+	return output, nil
+}
+
+func (g *GoogleVertexAIClient) GetName() string {
+	return googleVertexAIClientName
+}
+
+func (g *GoogleVertexAIClient) Close() {
+	if err := g.client.Close(); err != nil {
+		color.Red("googleai client close error: %v", err)
+	}
+}
--- a/pkg/ai/iai.go
+++ b/pkg/ai/iai.go
@@ -28,6 +28,7 @@ var (
 		&SageMakerAIClient{},
 		&GoogleGenAIClient{},
 		&HuggingfaceClient{},
+		&GoogleVertexAIClient{},
 	}
 	Backends = []string{
 		openAIClientName,
@@ -39,6 +40,7 @@ var (
 		googleAIClientName,
 		noopAIClientName,
 		huggingfaceAIClientName,
+		googleVertexAIClientName,
 	}
 )

@@ -64,12 +66,14 @@ type IAIConfig interface {
 	GetPassword() string
 	GetModel() string
 	GetBaseURL() string
+	GetProxyEndpoint() string
 	GetEndpointName() string
 	GetEngine() string
 	GetTemperature() float32
 	GetProviderRegion() string
 	GetTopP() float32
 	GetMaxTokens() int
+	GetProviderId() string
 }

 func NewClient(provider string) IAI {
@@ -92,10 +96,13 @@ type AIProvider struct {
 	Model          string  `mapstructure:"model"`
 	Password       string  `mapstructure:"password" yaml:"password,omitempty"`
 	BaseURL        string  `mapstructure:"baseurl" yaml:"baseurl,omitempty"`
+	ProxyEndpoint  string  `mapstructure:"proxyEndpoint" yaml:"proxyEndpoint,omitempty"`
+	ProxyPort      string  `mapstructure:"proxyPort" yaml:"proxyPort,omitempty"`
 	EndpointName   string  `mapstructure:"endpointname" yaml:"endpointname,omitempty"`
 	Engine         string  `mapstructure:"engine" yaml:"engine,omitempty"`
 	Temperature    float32 `mapstructure:"temperature" yaml:"temperature,omitempty"`
 	ProviderRegion string  `mapstructure:"providerregion" yaml:"providerregion,omitempty"`
+	ProviderId     string  `mapstructure:"providerid" yaml:"providerid,omitempty"`
 	TopP           float32 `mapstructure:"topp" yaml:"topp,omitempty"`
 	MaxTokens      int     `mapstructure:"maxtokens" yaml:"maxtokens,omitempty"`
 }
@@ -104,6 +111,10 @@ func (p *AIProvider) GetBaseURL() string {
 	return p.BaseURL
 }

+func (p *AIProvider) GetProxyEndpoint() string {
+	return p.ProxyEndpoint
+}
+
 func (p *AIProvider) GetEndpointName() string {
 	return p.EndpointName
 }
@@ -135,7 +146,11 @@ func (p *AIProvider) GetProviderRegion() string {
 	return p.ProviderRegion
 }

-var passwordlessProviders = []string{"localai", "amazonsagemaker", "amazonbedrock"}
+func (p *AIProvider) GetProviderId() string {
+	return p.ProviderId
+}
+
+var passwordlessProviders = []string{"localai", "amazonsagemaker", "amazonbedrock", "googlevertexai"}

 func NeedPassword(backend string) bool {
 	for _, b := range passwordlessProviders {
--- a/pkg/ai/openai.go
+++ b/pkg/ai/openai.go
@@ -16,6 +16,8 @@ package ai
 import (
 	"context"
 	"errors"
+	"net/http"
+	"net/url"

 	"github.com/sashabaranov/go-openai"
 )
@@ -41,12 +43,27 @@ const (
 func (c *OpenAIClient) Configure(config IAIConfig) error {
 	token := config.GetPassword()
 	defaultConfig := openai.DefaultConfig(token)
+	proxyEndpoint := config.GetProxyEndpoint()

 	baseURL := config.GetBaseURL()
 	if baseURL != "" {
 		defaultConfig.BaseURL = baseURL
 	}

+	if proxyEndpoint != "" {
+		proxyUrl, err := url.Parse(proxyEndpoint)
+		if err != nil {
+			return err
+		}
+		transport := &http.Transport{
+			Proxy: http.ProxyURL(proxyUrl),
+		}
+
+		defaultConfig.HTTPClient = &http.Client{
+			Transport: transport,
+		}
+	}
+	
 	client := openai.NewClientWithConfig(defaultConfig)
 	if client == nil {
 		return errors.New("error creating OpenAI client")
--- a/pkg/analysis/analysis.go
+++ b/pkg/analysis/analysis.go
@@ -124,11 +124,15 @@ func NewAnalysis(
 	}

 	// Backend string will have high priority than a default provider
-	// Backend as "openai" represents the default CLI argument passed through
-	if configAI.DefaultProvider != "" && backend == "openai" {
+	// Hence, use the default provider only if the backend is not specified by the user.
+	if configAI.DefaultProvider != "" && backend == "" {
 		backend = configAI.DefaultProvider
 	}

+	if backend == "" {
+		backend = "openai"
+	}
+
 	var aiProvider ai.AIProvider
 	for _, provider := range configAI.Providers {
 		if backend == provider.Name {
--- a/pkg/analyzer/cronjob.go
+++ b/pkg/analyzer/cronjob.go
@@ -123,15 +123,15 @@ func (analyzer CronJobAnalyzer) Analyze(a common.Analyzer) ([]common.Result, err
 			AnalyzerErrorsMetric.WithLabelValues(kind, cronJob.Name, cronJob.Namespace).Set(float64(len(failures)))

 		}
+	}

-		for key, value := range preAnalysis {
-			currentAnalysis := common.Result{
-				Kind:  kind,
-				Name:  key,
-				Error: value.FailureDetails,
-			}
-			a.Results = append(a.Results, currentAnalysis)
+	for key, value := range preAnalysis {
+		currentAnalysis := common.Result{
+			Kind:  kind,
+			Name:  key,
+			Error: value.FailureDetails,
 		}
+		a.Results = append(a.Results, currentAnalysis)
 	}

 	return a.Results, nil
--- a/pkg/analyzer/cronjob_test.go
+++ b/pkg/analyzer/cronjob_test.go
@@ -15,219 +15,144 @@ package analyzer

 import (
 	"context"
+	"sort"
 	"testing"

 	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
-	"github.com/magiconair/properties/assert"
+	"github.com/stretchr/testify/require"
 	batchv1 "k8s.io/api/batch/v1"
 	v1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/client-go/kubernetes/fake"
 )

-func TestCronJobSuccess(t *testing.T) {
-	clientset := fake.NewSimpleClientset(&batchv1.CronJob{
-		ObjectMeta: metav1.ObjectMeta{
-			Name:      "example-cronjob",
-			Namespace: "default",
-			Annotations: map[string]string{
-				"analysisDate": "2022-04-01",
-			},
-			Labels: map[string]string{
-				"app": "example-app",
-			},
-		},
-		Spec: batchv1.CronJobSpec{
-			Schedule:          "*/1 * * * *",
-			ConcurrencyPolicy: "Allow",
-			JobTemplate: batchv1.JobTemplateSpec{
-				ObjectMeta: metav1.ObjectMeta{
-					Labels: map[string]string{
-						"app": "example-app",
-					},
-				},
-				Spec: batchv1.JobSpec{
-					Template: v1.PodTemplateSpec{
-						Spec: v1.PodSpec{
-							Containers: []v1.Container{
-								{
-									Name:  "example-container",
-									Image: "nginx",
-								},
-							},
-							RestartPolicy: v1.RestartPolicyOnFailure,
-						},
-					},
-				},
-			},
-		},
-	})
+func TestCronJobAnalyzer(t *testing.T) {
+	suspend := new(bool)
+	*suspend = true
+
+	invalidStartingDeadline := new(int64)
+	*invalidStartingDeadline = -7
+
+	validStartingDeadline := new(int64)
+	*validStartingDeadline = 7

 	config := common.Analyzer{
 		Client: &kubernetes.Client{
-			Client: clientset,
-		},
-		Context:   context.Background(),
-		Namespace: "default",
-	}
-
-	analyzer := CronJobAnalyzer{}
-	analysisResults, err := analyzer.Analyze(config)
-	if err != nil {
-		t.Error(err)
-	}
-
-	assert.Equal(t, len(analysisResults), 0)
-}
-
-func TestCronJobBroken(t *testing.T) {
-	clientset := fake.NewSimpleClientset(&batchv1.CronJob{
-		ObjectMeta: metav1.ObjectMeta{
-			Name:      "example-cronjob",
-			Namespace: "default",
-			Annotations: map[string]string{
-				"analysisDate": "2022-04-01",
-			},
-			Labels: map[string]string{
-				"app": "example-app",
-			},
-		},
-		Spec: batchv1.CronJobSpec{
-			Schedule:          "*** * * * *",
-			ConcurrencyPolicy: "Allow",
-			JobTemplate: batchv1.JobTemplateSpec{
-				ObjectMeta: metav1.ObjectMeta{
-					Labels: map[string]string{
-						"app": "example-app",
-					},
-				},
-				Spec: batchv1.JobSpec{
-					Template: v1.PodTemplateSpec{
-						Spec: v1.PodSpec{
-							Containers: []v1.Container{
-								{
-									Name:  "example-container",
-									Image: "nginx",
-								},
-							},
-							RestartPolicy: v1.RestartPolicyOnFailure,
-						},
-					},
-				},
-			},
-		},
-	})
-
-	config := common.Analyzer{
-		Client: &kubernetes.Client{
-			Client: clientset,
-		},
-		Context:   context.Background(),
-		Namespace: "default",
-	}
-
-	analyzer := CronJobAnalyzer{}
-	analysisResults, err := analyzer.Analyze(config)
-	if err != nil {
-		t.Error(err)
-	}
-
-	assert.Equal(t, len(analysisResults), 1)
-	assert.Equal(t, analysisResults[0].Name, "default/example-cronjob")
-	assert.Equal(t, analysisResults[0].Kind, "CronJob")
-}
-
-func TestCronJobBrokenMultipleNamespaceFiltering(t *testing.T) {
-	clientset := fake.NewSimpleClientset(
-		&batchv1.CronJob{
-			ObjectMeta: metav1.ObjectMeta{
-				Name:      "example-cronjob",
-				Namespace: "default",
-				Annotations: map[string]string{
-					"analysisDate": "2022-04-01",
-				},
-				Labels: map[string]string{
-					"app": "example-app",
-				},
-			},
-			Spec: batchv1.CronJobSpec{
-				Schedule:          "*** * * * *",
-				ConcurrencyPolicy: "Allow",
-				JobTemplate: batchv1.JobTemplateSpec{
+			Client: fake.NewSimpleClientset(
+				&batchv1.CronJob{
 					ObjectMeta: metav1.ObjectMeta{
+						Name: "CJ1",
+						// This CronJob won't be list because of namespace filtering.
+						Namespace: "test",
+					},
+				},
+				&batchv1.CronJob{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "CJ2",
+						Namespace: "default",
+					},
+					// A suspended CronJob will contribute to failures.
+					Spec: batchv1.CronJobSpec{
+						Suspend: suspend,
+					},
+				},
+				&batchv1.CronJob{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "CJ3",
+						Namespace: "default",
+					},
+					Spec: batchv1.CronJobSpec{
+						// Valid schedule
+						Schedule: "*/1 * * * *",
+
+						// Negative starting deadline
+						StartingDeadlineSeconds: invalidStartingDeadline,
+					},
+				},
+				&batchv1.CronJob{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "CJ4",
+						Namespace: "default",
+					},
+					Spec: batchv1.CronJobSpec{
+						// Invalid schedule
+						Schedule: "*** * * * *",
+					},
+				},
+				&batchv1.CronJob{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "CJ5",
+						Namespace: "default",
+					},
+					Spec: batchv1.CronJobSpec{
+						// Valid schedule
+						Schedule: "*/1 * * * *",
+
+						// Positive starting deadline shouldn't be any problem.
+						StartingDeadlineSeconds: validStartingDeadline,
+					},
+				},
+				&batchv1.CronJob{
+					// This cronjob shouldn't contribute to any failures.
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "successful-cronjob",
+						Namespace: "default",
+						Annotations: map[string]string{
+							"analysisDate": "2022-04-01",
+						},
 						Labels: map[string]string{
 							"app": "example-app",
 						},
 					},
-					Spec: batchv1.JobSpec{
-						Template: v1.PodTemplateSpec{
-							Spec: v1.PodSpec{
-								Containers: []v1.Container{
-									{
-										Name:  "example-container",
-										Image: "nginx",
+					Spec: batchv1.CronJobSpec{
+						Schedule:          "*/1 * * * *",
+						ConcurrencyPolicy: "Allow",
+						JobTemplate: batchv1.JobTemplateSpec{
+							ObjectMeta: metav1.ObjectMeta{
+								Labels: map[string]string{
+									"app": "example-app",
+								},
+							},
+							Spec: batchv1.JobSpec{
+								Template: v1.PodTemplateSpec{
+									Spec: v1.PodSpec{
+										Containers: []v1.Container{
+											{
+												Name:  "example-container",
+												Image: "nginx",
+											},
+										},
+										RestartPolicy: v1.RestartPolicyOnFailure,
 									},
 								},
-								RestartPolicy: v1.RestartPolicyOnFailure,
 							},
 						},
 					},
 				},
-			},
-		},
-		&batchv1.CronJob{
-			ObjectMeta: metav1.ObjectMeta{
-				Name:      "example-cronjob",
-				Namespace: "other-namespace",
-				Annotations: map[string]string{
-					"analysisDate": "2022-04-01",
-				},
-				Labels: map[string]string{
-					"app": "example-app",
-				},
-			},
-			Spec: batchv1.CronJobSpec{
-				Schedule:          "*** * * * *",
-				ConcurrencyPolicy: "Allow",
-				JobTemplate: batchv1.JobTemplateSpec{
-					ObjectMeta: metav1.ObjectMeta{
-						Labels: map[string]string{
-							"app": "example-app",
-						},
-					},
-					Spec: batchv1.JobSpec{
-						Template: v1.PodTemplateSpec{
-							Spec: v1.PodSpec{
-								Containers: []v1.Container{
-									{
-										Name:  "example-container",
-										Image: "nginx",
-									},
-								},
-								RestartPolicy: v1.RestartPolicyOnFailure,
-							},
-						},
-					},
-				},
-			},
-		})
-
-	config := common.Analyzer{
-		Client: &kubernetes.Client{
-			Client: clientset,
+			),
 		},
 		Context:   context.Background(),
 		Namespace: "default",
 	}

-	analyzer := CronJobAnalyzer{}
-	analysisResults, err := analyzer.Analyze(config)
-	if err != nil {
-		t.Error(err)
+	cjAnalyzer := CronJobAnalyzer{}
+	results, err := cjAnalyzer.Analyze(config)
+	require.NoError(t, err)
+
+	sort.Slice(results, func(i, j int) bool {
+		return results[i].Name < results[j].Name
+	})
+
+	expectations := []string{
+		"default/CJ2",
+		"default/CJ3",
+		"default/CJ4",
 	}

-	assert.Equal(t, len(analysisResults), 1)
-	assert.Equal(t, analysisResults[0].Name, "default/example-cronjob")
-	assert.Equal(t, analysisResults[0].Kind, "CronJob")
+	require.Equal(t, len(expectations), len(results))
+
+	for i, result := range results {
+		require.Equal(t, expectations[i], result.Name)
+	}
 }
--- a/pkg/analyzer/ingress_test.go
+++ b/pkg/analyzer/ingress_test.go
@@ -15,146 +15,189 @@ package analyzer

 import (
 	"context"
-	"strings"
+	"sort"
 	"testing"

 	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
-	"github.com/magiconair/properties/assert"
+	"github.com/stretchr/testify/require"
+	v1 "k8s.io/api/core/v1"
 	networkingv1 "k8s.io/api/networking/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/client-go/kubernetes/fake"
 )

 func TestIngressAnalyzer(t *testing.T) {
-	clientset := fake.NewSimpleClientset(
-		&networkingv1.Ingress{
-			ObjectMeta: metav1.ObjectMeta{
-				Name:        "example",
-				Namespace:   "default",
-				Annotations: map[string]string{},
+	validIgClassName := new(string)
+	*validIgClassName = "valid-ingress-class"
+
+	var igRule networkingv1.IngressRule
+
+	httpRule := networkingv1.HTTPIngressRuleValue{
+		Paths: []networkingv1.HTTPIngressPath{
+			{
+				Path: "/",
+				Backend: networkingv1.IngressBackend{
+					Service: &networkingv1.IngressServiceBackend{
+						// This service exists.
+						Name: "Service1",
+					},
+				},
 			},
-		})
-	ingressAnalyzer := IngressAnalyzer{}
+			{
+				Path: "/test1",
+				Backend: networkingv1.IngressBackend{
+					Service: &networkingv1.IngressServiceBackend{
+						// This service is in the test namespace
+						// Hence, it won't be discovered.
+						Name: "Service2",
+					},
+				},
+			},
+			{
+				Path: "/test2",
+				Backend: networkingv1.IngressBackend{
+					Service: &networkingv1.IngressServiceBackend{
+						// This service doesn't exist.
+						Name: "Service3",
+					},
+				},
+			},
+		},
+	}
+	igRule.IngressRuleValue.HTTP = &httpRule

 	config := common.Analyzer{
 		Client: &kubernetes.Client{
-			Client: clientset,
-		},
-		Context:   context.Background(),
-		Namespace: "default",
-	}
-	analysisResults, err := ingressAnalyzer.Analyze(config)
-	if err != nil {
-		t.Error(err)
-	}
-	assert.Equal(t, len(analysisResults), 1)
-}
+			Client: fake.NewSimpleClientset(
+				&networkingv1.Ingress{
+					// Doesn't specify an ingress class.
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Ingress1",
+						Namespace: "default",
+					},
+				},
+				&networkingv1.Ingress{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Ingress2",
+						Namespace: "default",
+						// Specify an invalid ingress class name using annotations.
+						Annotations: map[string]string{
+							"kubernetes.io/ingress.class": "invalid-class",
+						},
+					},
+				},
+				&networkingv1.Ingress{
+					// Namespace filtering.
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Ingress3",
+						Namespace: "test",
+					},
+				},
+				&networkingv1.IngressClass{
+					ObjectMeta: metav1.ObjectMeta{
+						Name: *validIgClassName,
+					},
+				},
+				&networkingv1.Ingress{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Ingress4",
+						Namespace: "default",
+						// Specify valid ingress class name using annotations.
+						Annotations: map[string]string{
+							"kubernetes.io/ingress.class": *validIgClassName,
+						},
+					},
+				},
+				&v1.Service{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Service1",
+						Namespace: "default",
+					},
+				},
+				&v1.Service{
+					ObjectMeta: metav1.ObjectMeta{
+						// Namespace filtering.
+						Name:      "Service2",
+						Namespace: "test",
+					},
+				},
+				&v1.Secret{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Secret1",
+						Namespace: "default",
+					},
+				},
+				&v1.Secret{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Secret2",
+						Namespace: "test",
+					},
+				},
+				&networkingv1.Ingress{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Ingress5",
+						Namespace: "default",
+					},

-func TestIngressAnalyzerWithMultipleIngresses(t *testing.T) {
-	clientset := fake.NewSimpleClientset(
-		&networkingv1.Ingress{
-			ObjectMeta: metav1.ObjectMeta{
-				Name:        "example",
-				Namespace:   "default",
-				Annotations: map[string]string{},
-			},
-		},
-		&networkingv1.Ingress{
-			ObjectMeta: metav1.ObjectMeta{
-				Name:        "example-2",
-				Namespace:   "default",
-				Annotations: map[string]string{},
-			},
-		},
-	)
-	ingressAnalyzer := IngressAnalyzer{}
-
-	config := common.Analyzer{
-		Client: &kubernetes.Client{
-			Client: clientset,
+					// Specify valid ingress class name in spec.
+					Spec: networkingv1.IngressSpec{
+						IngressClassName: validIgClassName,
+						Rules: []networkingv1.IngressRule{
+							igRule,
+						},
+						TLS: []networkingv1.IngressTLS{
+							{
+								// This won't contribute to any failures.
+								SecretName: "Secret1",
+							},
+							{
+								// This secret won't be discovered because of namespace filtering.
+								SecretName: "Secret2",
+							},
+							{
+								// This secret doesn't exist.
+								SecretName: "Secret3",
+							},
+						},
+					},
+				},
+			),
 		},
 		Context:   context.Background(),
 		Namespace: "default",
 	}

-	analysisResults, err := ingressAnalyzer.Analyze(config)
-	if err != nil {
-		t.Error(err)
-	}
-	assert.Equal(t, len(analysisResults), 2)
-}
+	igAnalyzer := IngressAnalyzer{}
+	results, err := igAnalyzer.Analyze(config)
+	require.NoError(t, err)

-func TestIngressAnalyzerWithoutIngressClassAnnotation(t *testing.T) {
+	sort.Slice(results, func(i, j int) bool {
+		return results[i].Name < results[j].Name
+	})

-	clientset := fake.NewSimpleClientset(
-		&networkingv1.Ingress{
-			ObjectMeta: metav1.ObjectMeta{
-				Name:        "example",
-				Namespace:   "default",
-				Annotations: map[string]string{},
-			},
-		})
-	ingressAnalyzer := IngressAnalyzer{}
-
-	config := common.Analyzer{
-		Client: &kubernetes.Client{
-			Client: clientset,
+	expectations := []struct {
+		name          string
+		failuresCount int
+	}{
+		{
+			name:          "default/Ingress1",
+			failuresCount: 1,
+		},
+		{
+			name:          "default/Ingress2",
+			failuresCount: 1,
+		},
+		{
+			name:          "default/Ingress5",
+			failuresCount: 4,
 		},
-		Context:   context.Background(),
-		Namespace: "default",
 	}

-	analysisResults, err := ingressAnalyzer.Analyze(config)
-	if err != nil {
-		t.Error(err)
-	}
+	require.Equal(t, len(expectations), len(results))

-	var errorFound bool
-	for _, analysis := range analysisResults {
-		for _, err := range analysis.Error {
-			if strings.Contains(err.Text, "does not specify an Ingress class") {
-				errorFound = true
-				break
-			}
-		}
-		if errorFound {
-			break
-		}
-	}
-	if !errorFound {
-		t.Error("expected error 'does not specify an Ingress class' not found in analysis results")
+	for i, result := range results {
+		require.Equal(t, expectations[i].name, result.Name)
+		require.Equal(t, expectations[i].failuresCount, len(result.Error))
 	}
 }
-
-func TestIngressAnalyzerNamespaceFiltering(t *testing.T) {
-	clientset := fake.NewSimpleClientset(
-		&networkingv1.Ingress{
-			ObjectMeta: metav1.ObjectMeta{
-				Name:        "example",
-				Namespace:   "default",
-				Annotations: map[string]string{},
-			},
-		},
-		&networkingv1.Ingress{
-			ObjectMeta: metav1.ObjectMeta{
-				Name:        "example",
-				Namespace:   "other-namespace",
-				Annotations: map[string]string{},
-			},
-		})
-	ingressAnalyzer := IngressAnalyzer{}
-
-	config := common.Analyzer{
-		Client: &kubernetes.Client{
-			Client: clientset,
-		},
-		Context:   context.Background(),
-		Namespace: "default",
-	}
-	analysisResults, err := ingressAnalyzer.Analyze(config)
-	if err != nil {
-		t.Error(err)
-	}
-	assert.Equal(t, len(analysisResults), 1)
-}
--- a/pkg/analyzer/log.go
+++ b/pkg/analyzer/log.go
@@ -49,29 +49,17 @@ func (LogAnalyzer) Analyze(a common.Analyzer) ([]common.Result, error) {
 	// Iterate through each pod

 	for _, pod := range list.Items {
-		var failures []common.Failure
 		podName := pod.Name
-		podLogOptions := v1.PodLogOptions{
-			TailLines: &tailLines,
-		}
-
-		podLogs, err := a.Client.Client.CoreV1().Pods(pod.Namespace).GetLogs(podName, &podLogOptions).DoRaw(a.Context)
-		if err != nil {
-			failures = append(failures, common.Failure{
-				Text: fmt.Sprintf("Error %s from Pod %s", err.Error(), pod.Name),
-				Sensitive: []common.Sensitive{
-					{
-						Unmasked: pod.Name,
-						Masked:   util.MaskString(pod.Name),
-					},
-				},
-			})
-
-		} else {
-			rawlogs := string(podLogs)
-			if errorPattern.MatchString(strings.ToLower(rawlogs)) {
+		for _, c := range pod.Spec.Containers {
+			var failures []common.Failure
+			podLogOptions := v1.PodLogOptions{
+				TailLines: &tailLines,
+				Container: c.Name,
+			}
+			podLogs, err := a.Client.Client.CoreV1().Pods(pod.Namespace).GetLogs(podName, &podLogOptions).DoRaw(a.Context)
+			if err != nil {
 				failures = append(failures, common.Failure{
-					Text: printErrorLines(pod.Name, pod.Namespace, rawlogs, errorPattern),
+					Text: fmt.Sprintf("Error %s from Pod %s", err.Error(), pod.Name),
 					Sensitive: []common.Sensitive{
 						{
 							Unmasked: pod.Name,
@@ -79,14 +67,27 @@ func (LogAnalyzer) Analyze(a common.Analyzer) ([]common.Result, error) {
 						},
 					},
 				})
+			} else {
+				rawlogs := string(podLogs)
+				if errorPattern.MatchString(strings.ToLower(rawlogs)) {
+					failures = append(failures, common.Failure{
+						Text: printErrorLines(pod.Name, pod.Namespace, rawlogs, errorPattern),
+						Sensitive: []common.Sensitive{
+							{
+								Unmasked: pod.Name,
+								Masked:   util.MaskString(pod.Name),
+							},
+						},
+					})
+				}
 			}
-		}
-		if len(failures) > 0 {
-			preAnalysis[fmt.Sprintf("%s/%s", pod.Namespace, pod.Name)] = common.PreAnalysis{
-				FailureDetails: failures,
-				Pod:            pod,
+			if len(failures) > 0 {
+				preAnalysis[fmt.Sprintf("%s/%s/%s", pod.Namespace, pod.Name, c.Name)] = common.PreAnalysis{
+					FailureDetails: failures,
+					Pod:            pod,
+				}
+				AnalyzerErrorsMetric.WithLabelValues(kind, pod.Name, pod.Namespace).Set(float64(len(failures)))
 			}
-			AnalyzerErrorsMetric.WithLabelValues(kind, pod.Name, pod.Namespace).Set(float64(len(failures)))
 		}
 	}
 	for key, value := range preAnalysis {
--- a/pkg/analyzer/mutating_webhook_test.go
+++ b/pkg/analyzer/mutating_webhook_test.go
@@ -0,0 +1,140 @@
+/*
+Copyright 2024 The K8sGPT Authors.
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+    http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package analyzer
+
+import (
+	"context"
+	"testing"
+
+	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
+	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
+	"github.com/stretchr/testify/require"
+	admissionregistrationv1 "k8s.io/api/admissionregistration/v1"
+	v1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/client-go/kubernetes/fake"
+)
+
+func TestMutatingWebhookAnalyzer(t *testing.T) {
+	config := common.Analyzer{
+		Client: &kubernetes.Client{
+			Client: fake.NewSimpleClientset(
+				&v1.Pod{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Pod1",
+						Namespace: "default",
+						Labels: map[string]string{
+							"pod": "Pod1",
+						},
+					},
+				},
+				&v1.Service{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "test-service1",
+						Namespace: "default",
+					},
+					Spec: v1.ServiceSpec{
+						Selector: map[string]string{
+							"pod": "Pod1",
+						},
+					},
+				},
+				&v1.Service{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "test-service2",
+						Namespace: "test",
+					},
+					Spec: v1.ServiceSpec{
+						// No such pod exists in the test namespace
+						Selector: map[string]string{
+							"pod": "Pod2",
+						},
+					},
+				},
+				&v1.Service{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "test-service3",
+						Namespace: "test",
+					},
+					Spec: v1.ServiceSpec{
+						// len(service.Spec.Selector) == 0
+						Selector: map[string]string{},
+					},
+				},
+				&admissionregistrationv1.MutatingWebhookConfiguration{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "test-mutating-webhook-config",
+						Namespace: "test",
+					},
+					Webhooks: []admissionregistrationv1.MutatingWebhook{
+						{
+							// Failure: Pointing to an inactive receiver pod
+							Name: "webhook1",
+							ClientConfig: admissionregistrationv1.WebhookClientConfig{
+								Service: &admissionregistrationv1.ServiceReference{
+									Name:      "test-service1",
+									Namespace: "default",
+								},
+							},
+						},
+						{
+							// Failure: No active pods found in the test namespace
+							Name: "webhook2",
+							ClientConfig: admissionregistrationv1.WebhookClientConfig{
+								Service: &admissionregistrationv1.ServiceReference{
+									Name:      "test-service2",
+									Namespace: "test",
+								},
+							},
+						},
+						{
+							Name: "webhook3",
+							ClientConfig: admissionregistrationv1.WebhookClientConfig{
+								Service: &admissionregistrationv1.ServiceReference{
+									Name:      "test-service3",
+									Namespace: "test",
+								},
+							},
+						},
+						{
+							// Failure: Service doesn't exist.
+							Name: "webhook4",
+							ClientConfig: admissionregistrationv1.WebhookClientConfig{
+								Service: &admissionregistrationv1.ServiceReference{
+									Name:      "test-service4-doesn't-exist",
+									Namespace: "test",
+								},
+							},
+						},
+						{
+							// Service is nil.
+							Name:         "webhook5",
+							ClientConfig: admissionregistrationv1.WebhookClientConfig{},
+						},
+					},
+				},
+			),
+		},
+		Context:   context.Background(),
+		Namespace: "default",
+	}
+
+	mwAnalyzer := MutatingWebhookAnalyzer{}
+	results, err := mwAnalyzer.Analyze(config)
+	require.NoError(t, err)
+
+	// The results should contain: webhook1, webhook2, and webhook4
+	resultsLen := 3
+	require.Equal(t, resultsLen, len(results))
+}
--- a/pkg/analyzer/netpol_test.go
+++ b/pkg/analyzer/netpol_test.go
@@ -136,6 +136,19 @@ func TestNetpolWithPod(t *testing.T) {

 func TestNetpolNoPodsNamespaceFiltering(t *testing.T) {
 	clientset := fake.NewSimpleClientset(
+		&networkingv1.NetworkPolicy{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      "policy-without-podselector-match-labels",
+				Namespace: "default",
+			},
+			Spec: networkingv1.NetworkPolicySpec{
+				PodSelector: metav1.LabelSelector{
+					// len(MatchLabels) == 0 should trigger a failure.
+					// Allowing traffic to all pods.
+					MatchLabels: map[string]string{},
+				},
+			},
+		},
 		&networkingv1.NetworkPolicy{
 			ObjectMeta: metav1.ObjectMeta{
 				Name:      "example",
@@ -203,7 +216,7 @@ func TestNetpolNoPodsNamespaceFiltering(t *testing.T) {
 		t.Error(err)
 	}

-	assert.Equal(t, len(results), 1)
+	assert.Equal(t, len(results), 2)
 	assert.Equal(t, results[0].Kind, "NetworkPolicy")

 }
--- a/pkg/analyzer/node_test.go
+++ b/pkg/analyzer/node_test.go
@@ -15,110 +15,155 @@ package analyzer

 import (
 	"context"
+	"sort"
 	"testing"

 	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
-	"github.com/magiconair/properties/assert"
+	"github.com/stretchr/testify/require"
 	v1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/client-go/kubernetes/fake"
 )

-func TestNodeAnalyzerNodeReady(t *testing.T) {
-	clientset := fake.NewSimpleClientset(&v1.Node{
-		ObjectMeta: metav1.ObjectMeta{
-			Name: "node1",
-		},
-		Status: v1.NodeStatus{
-			Conditions: []v1.NodeCondition{
-				{
-					Type:    v1.NodeReady,
-					Status:  v1.ConditionTrue,
-					Reason:  "KubeletReady",
-					Message: "kubelet is posting ready status",
-				},
-			},
-		},
-	})
-
+func TestNodeAnalyzer(t *testing.T) {
 	config := common.Analyzer{
 		Client: &kubernetes.Client{
-			Client: clientset,
-		},
-		Context: context.Background(),
-	}
-	nodeAnalyzer := NodeAnalyzer{}
-	var analysisResults []common.Result
-	analysisResults, err := nodeAnalyzer.Analyze(config)
-	if err != nil {
-		t.Error(err)
-	}
-	assert.Equal(t, len(analysisResults), 0)
-}
-
-func TestNodeAnalyzerNodeDiskPressure(t *testing.T) {
-	clientset := fake.NewSimpleClientset(&v1.Node{
-		ObjectMeta: metav1.ObjectMeta{
-			Name: "node1",
-		},
-		Status: v1.NodeStatus{
-			Conditions: []v1.NodeCondition{
-				{
-					Type:    v1.NodeDiskPressure,
-					Status:  v1.ConditionTrue,
-					Reason:  "KubeletHasDiskPressure",
-					Message: "kubelet has disk pressure",
+			Client: fake.NewSimpleClientset(
+				&v1.Node{
+					// A node without Status Conditions shouldn't contribute to failures.
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Node1",
+						Namespace: "test",
+					},
 				},
-			},
+				&v1.Node{
+					// Nodes are not filtered using namespace.
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Node2",
+						Namespace: "default",
+					},
+					Status: v1.NodeStatus{
+						Conditions: []v1.NodeCondition{
+							{
+								// Won't contribute to failures.
+								Type:   v1.NodeReady,
+								Status: v1.ConditionTrue,
+							},
+							{
+								// Will contribute to failures.
+								Type:   v1.NodeReady,
+								Status: v1.ConditionFalse,
+							},
+							{
+								// Will contribute to failures.
+								Type:   v1.NodeReady,
+								Status: v1.ConditionUnknown,
+							},
+							// Non-false statuses for the default cases contribute to failures.
+							{
+								Type:   v1.NodeMemoryPressure,
+								Status: v1.ConditionTrue,
+							},
+							{
+								Type:   v1.NodeDiskPressure,
+								Status: v1.ConditionTrue,
+							},
+							{
+								Type:   v1.NodePIDPressure,
+								Status: v1.ConditionTrue,
+							},
+							{
+								Type:   v1.NodeNetworkUnavailable,
+								Status: v1.ConditionTrue,
+							},
+							{
+								Type:   v1.NodeMemoryPressure,
+								Status: v1.ConditionUnknown,
+							},
+							{
+								Type:   v1.NodeDiskPressure,
+								Status: v1.ConditionUnknown,
+							},
+							{
+								Type:   v1.NodePIDPressure,
+								Status: v1.ConditionUnknown,
+							},
+							{
+								Type:   v1.NodeNetworkUnavailable,
+								Status: v1.ConditionUnknown,
+							},
+							// A cloud provider may set their own condition and/or a new status
+							// might be introduced. In such cases a failure is assumed and
+							// the code shouldn't break, although it might be a false positive.
+							{
+								Type:   "UnknownNodeConditionType",
+								Status: "CompletelyUnknown",
+							},
+							// These won't contribute to failures.
+							{
+								Type:   v1.NodeMemoryPressure,
+								Status: v1.ConditionFalse,
+							},
+							{
+								Type:   v1.NodeDiskPressure,
+								Status: v1.ConditionFalse,
+							},
+							{
+								Type:   v1.NodePIDPressure,
+								Status: v1.ConditionFalse,
+							},
+							{
+								Type:   v1.NodeNetworkUnavailable,
+								Status: v1.ConditionFalse,
+							},
+						},
+					},
+				},
+				&v1.Node{
+					// A node without any failures shouldn't be present in the results.
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Node3",
+						Namespace: "test",
+					},
+					Status: v1.NodeStatus{
+						Conditions: []v1.NodeCondition{
+							{
+								// Won't contribute to failures.
+								Type:   v1.NodeReady,
+								Status: v1.ConditionTrue,
+							},
+						},
+					},
+				},
+			),
 		},
+		Context:   context.Background(),
+		Namespace: "test",
+	}
+
+	nAnalyzer := NodeAnalyzer{}
+	results, err := nAnalyzer.Analyze(config)
+	require.NoError(t, err)
+
+	sort.Slice(results, func(i, j int) bool {
+		return results[i].Name < results[j].Name
 	})

-	config := common.Analyzer{
-		Client: &kubernetes.Client{
-			Client: clientset,
+	expectations := []struct {
+		name          string
+		failuresCount int
+	}{
+		{
+			name:          "Node2",
+			failuresCount: 11,
 		},
-		Context: context.Background(),
 	}
-	nodeAnalyzer := NodeAnalyzer{}
-	var analysisResults []common.Result
-	analysisResults, err := nodeAnalyzer.Analyze(config)
-	if err != nil {
-		t.Error(err)
-	}
-	assert.Equal(t, len(analysisResults), 1)
-}

-// A cloud provider may set their own condition and/or a new status might be introduced
-// In such cases a failure is assumed and the code shouldn't break, although it might be a false positive
-func TestNodeAnalyzerNodeUnknownType(t *testing.T) {
-	clientset := fake.NewSimpleClientset(&v1.Node{
-		ObjectMeta: metav1.ObjectMeta{
-			Name: "node1",
-		},
-		Status: v1.NodeStatus{
-			Conditions: []v1.NodeCondition{
-				{
-					Type:    "UnknownNodeConditionType",
-					Status:  "CompletelyUnknown",
-					Reason:  "KubeletHasTheUnknown",
-					Message: "kubelet has the unknown",
-				},
-			},
-		},
-	})
+	require.Equal(t, len(expectations), len(results))

-	config := common.Analyzer{
-		Client: &kubernetes.Client{
-			Client: clientset,
-		},
-		Context: context.Background(),
+	for i, result := range results {
+		require.Equal(t, expectations[i].name, result.Name)
+		require.Equal(t, expectations[i].failuresCount, len(result.Error))
 	}
-	nodeAnalyzer := NodeAnalyzer{}
-	var analysisResults []common.Result
-	analysisResults, err := nodeAnalyzer.Analyze(config)
-	if err != nil {
-		t.Error(err)
-	}
-	assert.Equal(t, len(analysisResults), 1)
 }
--- a/pkg/analyzer/pdb.go
+++ b/pkg/analyzer/pdb.go
@@ -50,6 +50,11 @@ func (PdbAnalyzer) Analyze(a common.Analyzer) ([]common.Result, error) {

 	for _, pdb := range list.Items {
 		var failures []common.Failure
+
+		// Before accessing the Conditions, check if they exist or not.
+		if len(pdb.Status.Conditions) == 0 {
+			continue
+		}
 		if pdb.Status.Conditions[0].Type == "DisruptionAllowed" && pdb.Status.Conditions[0].Status == "False" {
 			var doc string
 			if pdb.Spec.MaxUnavailable != nil {
--- a/pkg/analyzer/pdb_test.go
+++ b/pkg/analyzer/pdb_test.go
@@ -0,0 +1,117 @@
+/*
+Copyright 2024 The K8sGPT Authors.
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+    http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package analyzer
+
+import (
+	"context"
+	"testing"
+
+	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
+	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
+	"github.com/stretchr/testify/require"
+	policyv1 "k8s.io/api/policy/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/util/intstr"
+	"k8s.io/client-go/kubernetes/fake"
+)
+
+func TestPodDisruptionBudgetAnalyzer(t *testing.T) {
+	config := common.Analyzer{
+		Client: &kubernetes.Client{
+			Client: fake.NewSimpleClientset(
+				&policyv1.PodDisruptionBudget{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "PDB1",
+						Namespace: "test",
+					},
+					// Status conditions are nil.
+					Status: policyv1.PodDisruptionBudgetStatus{
+						Conditions: nil,
+					},
+				},
+				&policyv1.PodDisruptionBudget{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "PDB2",
+						Namespace: "test",
+					},
+					// Status conditions are empty.
+					Status: policyv1.PodDisruptionBudgetStatus{
+						Conditions: []metav1.Condition{},
+					},
+				},
+				&policyv1.PodDisruptionBudget{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "PDB3",
+						Namespace: "test",
+					},
+					Status: policyv1.PodDisruptionBudgetStatus{
+						Conditions: []metav1.Condition{
+							{
+								Type:   "DisruptionAllowed",
+								Status: "False",
+								Reason: "test reason",
+							},
+						},
+					},
+					Spec: policyv1.PodDisruptionBudgetSpec{
+						MaxUnavailable: &intstr.IntOrString{
+							Type:   0,
+							IntVal: 17,
+							StrVal: "17",
+						},
+						MinAvailable: &intstr.IntOrString{
+							Type:   0,
+							IntVal: 7,
+							StrVal: "7",
+						},
+						// MatchLabels specified.
+						Selector: &metav1.LabelSelector{
+							MatchLabels: map[string]string{
+								"label1": "test1",
+								"label2": "test2",
+							},
+						},
+					},
+				},
+				&policyv1.PodDisruptionBudget{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "PDB4",
+						Namespace: "test",
+					},
+					Status: policyv1.PodDisruptionBudgetStatus{
+						Conditions: []metav1.Condition{
+							{
+								Type:   "DisruptionAllowed",
+								Status: "False",
+								Reason: "test reason",
+							},
+						},
+					},
+					// Match Labels Empty.
+					Spec: policyv1.PodDisruptionBudgetSpec{
+						Selector: &metav1.LabelSelector{},
+					},
+				},
+			),
+		},
+		Context:   context.Background(),
+		Namespace: "test",
+	}
+
+	pdbAnalyzer := PdbAnalyzer{}
+	results, err := pdbAnalyzer.Analyze(config)
+	require.NoError(t, err)
+	require.Equal(t, 1, len(results))
+	require.Equal(t, "test/PDB3", results[0].Name)
+}
--- a/pkg/analyzer/pvc.go
+++ b/pkg/analyzer/pvc.go
@@ -18,6 +18,7 @@ import (

 	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/util"
+	appsv1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )

@@ -43,7 +44,7 @@ func (PvcAnalyzer) Analyze(a common.Analyzer) ([]common.Result, error) {
 		var failures []common.Failure

 		// Check for empty rs
-		if pvc.Status.Phase == "Pending" {
+		if pvc.Status.Phase == appsv1.ClaimPending {

 			// parse the event log and append details
 			evt, err := FetchLatestEvent(a.Context, a.Client, pvc.Namespace, pvc.Name)
--- a/pkg/analyzer/pvc_test.go
+++ b/pkg/analyzer/pvc_test.go
@@ -0,0 +1,230 @@
+/*
+Copyright 2024 The K8sGPT Authors.
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+    http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package analyzer
+
+import (
+	"context"
+	"sort"
+	"testing"
+	"time"
+
+	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
+	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
+	"github.com/stretchr/testify/require"
+	appsv1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/client-go/kubernetes/fake"
+)
+
+func TestPersistentVolumeClaimAnalyzer(t *testing.T) {
+	tests := []struct {
+		name         string
+		config       common.Analyzer
+		expectations []string
+	}{
+		{
+			name: "PV1 and PVC5 report failures",
+			config: common.Analyzer{
+				Client: &kubernetes.Client{
+					Client: fake.NewSimpleClientset(
+						&appsv1.Event{
+							ObjectMeta: metav1.ObjectMeta{
+								Name:      "Event1",
+								Namespace: "default",
+							},
+							LastTimestamp: metav1.Time{
+								Time: time.Date(2024, 3, 15, 10, 0, 0, 0, time.UTC),
+							},
+							Reason:  "ProvisioningFailed",
+							Message: "PVC Event1 provisioning failed",
+						},
+						&appsv1.Event{
+							ObjectMeta: metav1.ObjectMeta{
+								// This event won't get selected.
+								Name:      "Event2",
+								Namespace: "test",
+							},
+						},
+						&appsv1.Event{
+							// This is the latest event.
+							ObjectMeta: metav1.ObjectMeta{
+								Name:      "Event3",
+								Namespace: "default",
+							},
+							LastTimestamp: metav1.Time{
+								Time: time.Date(2024, 4, 15, 10, 0, 0, 0, time.UTC),
+							},
+							Reason:  "ProvisioningFailed",
+							Message: "PVC Event3 provisioning failed",
+						},
+						&appsv1.PersistentVolumeClaim{
+							ObjectMeta: metav1.ObjectMeta{
+								Name:      "PVC1",
+								Namespace: "default",
+							},
+							Status: appsv1.PersistentVolumeClaimStatus{
+								Phase: appsv1.ClaimPending,
+							},
+						},
+						&appsv1.PersistentVolumeClaim{
+							ObjectMeta: metav1.ObjectMeta{
+								Name:      "PVC2",
+								Namespace: "default",
+							},
+							Status: appsv1.PersistentVolumeClaimStatus{
+								// Won't contribute to failures.
+								Phase: appsv1.ClaimBound,
+							},
+						},
+						&appsv1.PersistentVolumeClaim{
+							ObjectMeta: metav1.ObjectMeta{
+								Name:      "PVC3",
+								Namespace: "default",
+							},
+							Status: appsv1.PersistentVolumeClaimStatus{
+								// Won't contribute to failures.
+								Phase: appsv1.ClaimLost,
+							},
+						},
+						&appsv1.PersistentVolumeClaim{
+							// PVCs in namespace other than "default" won't be discovered.
+							ObjectMeta: metav1.ObjectMeta{
+								Name:      "PVC4",
+								Namespace: "test",
+							},
+							Status: appsv1.PersistentVolumeClaimStatus{
+								Phase: appsv1.ClaimLost,
+							},
+						},
+						&appsv1.PersistentVolumeClaim{
+							// PVCs in namespace other than "default" won't be discovered.
+							ObjectMeta: metav1.ObjectMeta{
+								Name:      "PVC5",
+								Namespace: "default",
+							},
+							Status: appsv1.PersistentVolumeClaimStatus{
+								Phase: appsv1.ClaimPending,
+							},
+						},
+					),
+				},
+				Context:   context.Background(),
+				Namespace: "default",
+			},
+			expectations: []string{
+				"default/PVC1",
+				"default/PVC5",
+			},
+		},
+		{
+			name: "no event",
+			config: common.Analyzer{
+				Client: &kubernetes.Client{
+					Client: fake.NewSimpleClientset(
+						&appsv1.PersistentVolumeClaim{
+							ObjectMeta: metav1.ObjectMeta{
+								Name:      "PVC1",
+								Namespace: "default",
+							},
+							Status: appsv1.PersistentVolumeClaimStatus{
+								Phase: appsv1.ClaimPending,
+							},
+						},
+					),
+				},
+				Context:   context.Background(),
+				Namespace: "default",
+			},
+		},
+		{
+			name: "event other than provision failure",
+			config: common.Analyzer{
+				Client: &kubernetes.Client{
+					Client: fake.NewSimpleClientset(
+						&appsv1.Event{
+							ObjectMeta: metav1.ObjectMeta{
+								Name:      "Event1",
+								Namespace: "default",
+							},
+							// Any reason other than ProvisioningFailed won't result in failure.
+							Reason: "UnknownReason",
+						},
+						&appsv1.PersistentVolumeClaim{
+							ObjectMeta: metav1.ObjectMeta{
+								Name:      "PVC1",
+								Namespace: "default",
+							},
+							Status: appsv1.PersistentVolumeClaimStatus{
+								Phase: appsv1.ClaimPending,
+							},
+						},
+					),
+				},
+				Context:   context.Background(),
+				Namespace: "default",
+			},
+		},
+		{
+			name: "event without error message",
+			config: common.Analyzer{
+				Client: &kubernetes.Client{
+					Client: fake.NewSimpleClientset(
+						&appsv1.Event{
+							ObjectMeta: metav1.ObjectMeta{
+								Name:      "Event1",
+								Namespace: "default",
+							},
+							// Event without any error message won't result in failure.
+							Reason: "ProvisioningFailed",
+						},
+						&appsv1.PersistentVolumeClaim{
+							ObjectMeta: metav1.ObjectMeta{
+								Name:      "PVC1",
+								Namespace: "default",
+							},
+							Status: appsv1.PersistentVolumeClaimStatus{
+								Phase: appsv1.ClaimPending,
+							},
+						},
+					),
+				},
+				Context:   context.Background(),
+				Namespace: "default",
+			},
+		},
+	}
+
+	pvcAnalyzer := PvcAnalyzer{}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			results, err := pvcAnalyzer.Analyze(tt.config)
+			require.NoError(t, err)
+
+			if tt.expectations == nil {
+				require.Equal(t, 0, len(results))
+			} else {
+				sort.Slice(results, func(i, j int) bool {
+					return results[i].Name < results[j].Name
+				})
+
+				require.Equal(t, len(tt.expectations), len(results))
+
+				for i, expectation := range tt.expectations {
+					require.Equal(t, expectation, results[i].Name)
+				}
+			}
+		})
+	}
+}
--- a/pkg/analyzer/rs_test.go
+++ b/pkg/analyzer/rs_test.go
@@ -0,0 +1,146 @@
+/*
+Copyright 2024 The K8sGPT Authors.
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+    http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package analyzer
+
+import (
+	"context"
+	"sort"
+	"testing"
+
+	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
+	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
+	"github.com/stretchr/testify/require"
+	appsv1 "k8s.io/api/apps/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/client-go/kubernetes/fake"
+)
+
+func TestReplicaSetAnalyzer(t *testing.T) {
+	config := common.Analyzer{
+		Client: &kubernetes.Client{
+			Client: fake.NewSimpleClientset(
+				&appsv1.ReplicaSet{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "ReplicaSet1",
+						Namespace: "default",
+					},
+					Status: appsv1.ReplicaSetStatus{
+						Replicas: 0,
+						Conditions: []appsv1.ReplicaSetCondition{
+							{
+								// Should contribute to failures.
+								Type:    appsv1.ReplicaSetReplicaFailure,
+								Reason:  "FailedCreate",
+								Message: "failed to create test replica set 1",
+							},
+						},
+					},
+				},
+				&appsv1.ReplicaSet{
+					// This replicaset won't be discovered as it is not in the
+					// default namespace.
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "ReplicaSet2",
+						Namespace: "test",
+					},
+				},
+				&appsv1.ReplicaSet{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "ReplicaSet3",
+						Namespace: "default",
+					},
+					Status: appsv1.ReplicaSetStatus{
+						Replicas: 0,
+						Conditions: []appsv1.ReplicaSetCondition{
+							{
+								Type: appsv1.ReplicaSetReplicaFailure,
+								// Should not be included in the failures.
+								Reason: "RandomError",
+							},
+						},
+					},
+				},
+				&appsv1.ReplicaSet{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "ReplicaSet4",
+						Namespace: "default",
+					},
+					Status: appsv1.ReplicaSetStatus{
+						Replicas: 0,
+						Conditions: []appsv1.ReplicaSetCondition{
+							{
+								// Should contribute to failures.
+								Type:    appsv1.ReplicaSetReplicaFailure,
+								Reason:  "FailedCreate",
+								Message: "failed to create test replica set 4 condition 1",
+							},
+							{
+								// Should not contribute to failures.
+								Type:   appsv1.ReplicaSetReplicaFailure,
+								Reason: "Unknown",
+							},
+							{
+								// Should not contribute to failures.
+								Type:    appsv1.ReplicaSetReplicaFailure,
+								Reason:  "FailedCreate",
+								Message: "failed to create test replica set 4 condition 3",
+							},
+						},
+					},
+				},
+				&appsv1.ReplicaSet{
+					// Replicaset without any failures.
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "ReplicaSet5",
+						Namespace: "default",
+					},
+					Status: appsv1.ReplicaSetStatus{
+						Replicas: 3,
+					},
+				},
+			),
+		},
+		Context:   context.Background(),
+		Namespace: "default",
+	}
+
+	rsAnalyzer := ReplicaSetAnalyzer{}
+	results, err := rsAnalyzer.Analyze(config)
+	require.NoError(t, err)
+
+	sort.Slice(results, func(i, j int) bool {
+		return results[i].Name < results[j].Name
+	})
+
+	expectations := []struct {
+		name          string
+		failuresCount int
+	}{
+		{
+			name:          "default/ReplicaSet1",
+			failuresCount: 1,
+		},
+		{
+			name:          "default/ReplicaSet4",
+			failuresCount: 2,
+		},
+	}
+
+	require.Equal(t, len(expectations), len(results))
+
+	for i, result := range results {
+		require.Equal(t, expectations[i].name, result.Name)
+		require.Equal(t, expectations[i].failuresCount, len(result.Error))
+	}
+}
--- a/pkg/analyzer/service.go
+++ b/pkg/analyzer/service.go
@@ -98,16 +98,18 @@ func (ServiceAnalyzer) Analyze(a common.Analyzer) ([]common.Result, error) {
 						count++
 						pods = append(pods, addresses.TargetRef.Kind+"/"+addresses.TargetRef.Name)
 					}
-
-					doc := apiDoc.GetApiDocV2("subsets.notReadyAddresses")
-
-					failures = append(failures, common.Failure{
-						Text:          fmt.Sprintf("Service has not ready endpoints, pods: %s, expected %d", pods, count),
-						KubernetesDoc: doc,
-						Sensitive:     []common.Sensitive{},
-					})
 				}
 			}
+
+			if count > 0 {
+				doc := apiDoc.GetApiDocV2("subsets.notReadyAddresses")
+
+				failures = append(failures, common.Failure{
+					Text:          fmt.Sprintf("Service has not ready endpoints, pods: %s, expected %d", pods, count),
+					KubernetesDoc: doc,
+					Sensitive:     []common.Sensitive{},
+				})
+			}
 		}

 		if len(failures) > 0 {
--- a/pkg/analyzer/service_test.go
+++ b/pkg/analyzer/service_test.go
@@ -15,108 +15,153 @@ package analyzer

 import (
 	"context"
+	"sort"
 	"testing"

 	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
-	"github.com/magiconair/properties/assert"
+	"github.com/stretchr/testify/require"
 	v1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/client-go/kubernetes/fake"
+	"k8s.io/client-go/tools/leaderelection/resourcelock"
 )

 func TestServiceAnalyzer(t *testing.T) {
-
-	clientset := fake.NewSimpleClientset(&v1.Endpoints{
-		ObjectMeta: metav1.ObjectMeta{
-			Name:        "example",
-			Namespace:   "default",
-			Annotations: map[string]string{},
-		},
-	},
-		&v1.Service{
-			ObjectMeta: metav1.ObjectMeta{
-				Name:        "example",
-				Namespace:   "default",
-				Annotations: map[string]string{},
-			},
-			Spec: v1.ServiceSpec{
-				Selector: map[string]string{
-					"app": "example",
-				},
-			}})
-
 	config := common.Analyzer{
 		Client: &kubernetes.Client{
-			Client: clientset,
+			Client: fake.NewSimpleClientset(
+				&v1.Endpoints{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Endpoint1",
+						Namespace: "test",
+					},
+					// Endpoint with non-zero subsets.
+					Subsets: []v1.EndpointSubset{
+						{
+							// These not ready end points will contribute to failures.
+							NotReadyAddresses: []v1.EndpointAddress{
+								{
+									TargetRef: &v1.ObjectReference{
+										Kind: "test-reference",
+										Name: "reference1",
+									},
+								},
+								{
+									TargetRef: &v1.ObjectReference{
+										Kind: "test-reference",
+										Name: "reference2",
+									},
+								},
+							},
+						},
+						{
+							// These not ready end points will contribute to failures.
+							NotReadyAddresses: []v1.EndpointAddress{
+								{
+									TargetRef: &v1.ObjectReference{
+										Kind: "test-reference",
+										Name: "reference3",
+									},
+								},
+							},
+						},
+					},
+				},
+				&v1.Endpoints{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Endpoint2",
+						Namespace: "test",
+						Annotations: map[string]string{
+							// Leader election record annotation key defined.
+							resourcelock.LeaderElectionRecordAnnotationKey: "this is okay",
+						},
+					},
+					// Endpoint with zero subsets.
+				},
+				&v1.Endpoints{
+					ObjectMeta: metav1.ObjectMeta{
+						// This won't contribute to any failures.
+						Name:        "non-existent-service",
+						Namespace:   "test",
+						Annotations: map[string]string{},
+					},
+					// Endpoint with zero subsets.
+				},
+				&v1.Endpoints{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:        "Service1",
+						Namespace:   "test",
+						Annotations: map[string]string{},
+					},
+					// Endpoint with zero subsets.
+				},
+				&v1.Service{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Service1",
+						Namespace: "test",
+					},
+					Spec: v1.ServiceSpec{
+						Selector: map[string]string{
+							"app1": "test-app1",
+							"app2": "test-app2",
+						},
+					},
+				},
+				&v1.Service{
+					ObjectMeta: metav1.ObjectMeta{
+						// This service won't be discovered.
+						Name:      "Service2",
+						Namespace: "default",
+					},
+					Spec: v1.ServiceSpec{
+						Selector: map[string]string{
+							"app1": "test-app1",
+							"app2": "test-app2",
+						},
+					},
+				},
+				&v1.Service{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Service3",
+						Namespace: "test",
+					},
+					Spec: v1.ServiceSpec{
+						// No Spec Selector
+					},
+				},
+			),
 		},
 		Context:   context.Background(),
-		Namespace: "default",
+		Namespace: "test",
 	}

-	serviceAnalyzer := ServiceAnalyzer{}
-	analysisResults, err := serviceAnalyzer.Analyze(config)
-	if err != nil {
-		t.Error(err)
+	sAnalyzer := ServiceAnalyzer{}
+	results, err := sAnalyzer.Analyze(config)
+	require.NoError(t, err)
+
+	sort.Slice(results, func(i, j int) bool {
+		return results[i].Name < results[j].Name
+	})
+
+	expectations := []struct {
+		name          string
+		failuresCount int
+	}{
+		{
+			name:          "test/Endpoint1",
+			failuresCount: 1,
+		},
+		{
+			name:          "test/Service1",
+			failuresCount: 2,
+		},
+	}
+
+	require.Equal(t, len(expectations), len(results))
+
+	for i, result := range results {
+		require.Equal(t, expectations[i].name, result.Name)
+		require.Equal(t, expectations[i].failuresCount, len(result.Error))
 	}
-	assert.Equal(t, len(analysisResults), 1)
-}
-
-func TestServiceAnalyzerNamespaceFiltering(t *testing.T) {
-
-	clientset := fake.NewSimpleClientset(
-		&v1.Endpoints{
-			ObjectMeta: metav1.ObjectMeta{
-				Name:        "example",
-				Namespace:   "default",
-				Annotations: map[string]string{},
-			},
-		},
-		&v1.Service{
-			ObjectMeta: metav1.ObjectMeta{
-				Name:        "example",
-				Namespace:   "default",
-				Annotations: map[string]string{},
-			},
-			Spec: v1.ServiceSpec{
-				Selector: map[string]string{
-					"app": "example",
-				},
-			},
-		},
-		&v1.Endpoints{
-			ObjectMeta: metav1.ObjectMeta{
-				Name:        "example",
-				Namespace:   "other-namespace",
-				Annotations: map[string]string{},
-			},
-		},
-		&v1.Service{
-			ObjectMeta: metav1.ObjectMeta{
-				Name:        "example",
-				Namespace:   "other-namespace",
-				Annotations: map[string]string{},
-			},
-			Spec: v1.ServiceSpec{
-				Selector: map[string]string{
-					"app": "example",
-				},
-			},
-		},
-	)
-
-	config := common.Analyzer{
-		Client: &kubernetes.Client{
-			Client: clientset,
-		},
-		Context:   context.Background(),
-		Namespace: "default",
-	}
-
-	serviceAnalyzer := ServiceAnalyzer{}
-	analysisResults, err := serviceAnalyzer.Analyze(config)
-	if err != nil {
-		t.Error(err)
-	}
-	assert.Equal(t, len(analysisResults), 1)
 }
--- a/pkg/analyzer/validating_webhook_test.go
+++ b/pkg/analyzer/validating_webhook_test.go
@@ -0,0 +1,140 @@
+/*
+Copyright 2024 The K8sGPT Authors.
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+    http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package analyzer
+
+import (
+	"context"
+	"testing"
+
+	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
+	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
+	"github.com/stretchr/testify/require"
+	admissionregistrationv1 "k8s.io/api/admissionregistration/v1"
+	v1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/client-go/kubernetes/fake"
+)
+
+func TestValidatingWebhookAnalyzer(t *testing.T) {
+	config := common.Analyzer{
+		Client: &kubernetes.Client{
+			Client: fake.NewSimpleClientset(
+				&v1.Pod{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "Pod1",
+						Namespace: "default",
+						Labels: map[string]string{
+							"pod": "Pod1",
+						},
+					},
+				},
+				&v1.Service{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "test-service1",
+						Namespace: "default",
+					},
+					Spec: v1.ServiceSpec{
+						Selector: map[string]string{
+							"pod": "Pod1",
+						},
+					},
+				},
+				&v1.Service{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "test-service2",
+						Namespace: "test",
+					},
+					Spec: v1.ServiceSpec{
+						// No such pod exists in the test namespace
+						Selector: map[string]string{
+							"pod": "Pod2",
+						},
+					},
+				},
+				&v1.Service{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "test-service3",
+						Namespace: "test",
+					},
+					Spec: v1.ServiceSpec{
+						// len(service.Spec.Selector) == 0
+						Selector: map[string]string{},
+					},
+				},
+				&admissionregistrationv1.ValidatingWebhookConfiguration{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      "test-validating-webhook-config",
+						Namespace: "test",
+					},
+					Webhooks: []admissionregistrationv1.ValidatingWebhook{
+						{
+							// Failure: Pointing to an inactive receiver pod
+							Name: "webhook1",
+							ClientConfig: admissionregistrationv1.WebhookClientConfig{
+								Service: &admissionregistrationv1.ServiceReference{
+									Name:      "test-service1",
+									Namespace: "default",
+								},
+							},
+						},
+						{
+							// Failure: No active pods found in the test namespace
+							Name: "webhook2",
+							ClientConfig: admissionregistrationv1.WebhookClientConfig{
+								Service: &admissionregistrationv1.ServiceReference{
+									Name:      "test-service2",
+									Namespace: "test",
+								},
+							},
+						},
+						{
+							Name: "webhook3",
+							ClientConfig: admissionregistrationv1.WebhookClientConfig{
+								Service: &admissionregistrationv1.ServiceReference{
+									Name:      "test-service3",
+									Namespace: "test",
+								},
+							},
+						},
+						{
+							// Failure: Service doesn't exist.
+							Name: "webhook4",
+							ClientConfig: admissionregistrationv1.WebhookClientConfig{
+								Service: &admissionregistrationv1.ServiceReference{
+									Name:      "test-service4-doesn't-exist",
+									Namespace: "test",
+								},
+							},
+						},
+						{
+							// Service is nil.
+							Name:         "webhook5",
+							ClientConfig: admissionregistrationv1.WebhookClientConfig{},
+						},
+					},
+				},
+			),
+		},
+		Context:   context.Background(),
+		Namespace: "default",
+	}
+
+	vwAnalyzer := ValidatingWebhookAnalyzer{}
+	results, err := vwAnalyzer.Analyze(config)
+	require.NoError(t, err)
+
+	// The results should contain: webhook1, webhook2, and webhook4
+	resultsLen := 3
+	require.Equal(t, resultsLen, len(results))
+}
--- a/pkg/integration/aws/aws.go
+++ b/pkg/integration/aws/aws.go
@@ -0,0 +1,85 @@
+package aws
+
+import (
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/aws/session"
+	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
+	"github.com/spf13/viper"
+	"os"
+)
+
+type AWS struct {
+	sess *session.Session
+}
+
+func (a *AWS) Deploy(namespace string) error {
+
+	return nil
+}
+
+func (a *AWS) UnDeploy(namespace string) error {
+	a.sess = nil
+	return nil
+}
+
+func (a *AWS) AddAnalyzer(mergedMap *map[string]common.IAnalyzer) {
+	// Check for AWS credentials in the environment
+	// https://docs.aws.amazon.com/cli/latest/userguide/cli-configure-envvars.html
+	if os.Getenv("AWS_ACCESS_KEY_ID") == "" || os.Getenv("AWS_SECRET_ACCESS_KEY") == "" {
+		panic("AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY must be set in the environment")
+	}
+
+	sess := session.Must(session.NewSessionWithOptions(session.Options{
+		SharedConfigState: session.SharedConfigEnable,
+		Config:            aws.Config{},
+	}))
+	a.sess = sess
+	(*mergedMap)["EKS"] = &EKSAnalyzer{
+		session: a.sess,
+	}
+}
+
+func (a *AWS) GetAnalyzerName() []string {
+
+	return []string{"EKS"}
+}
+
+func (a *AWS) GetNamespace() (string, error) {
+
+	return "", nil
+}
+
+func (a *AWS) OwnsAnalyzer(s string) bool {
+	for _, az := range a.GetAnalyzerName() {
+		if s == az {
+			return true
+		}
+	}
+	return false
+}
+
+func (a *AWS) isFilterActive() bool {
+	activeFilters := viper.GetStringSlice("active_filters")
+
+	for _, filter := range a.GetAnalyzerName() {
+		for _, af := range activeFilters {
+			if af == filter {
+				return true
+			}
+		}
+	}
+
+	return false
+}
+
+func (a *AWS) IsActivate() bool {
+	if a.isFilterActive() {
+		return true
+	} else {
+		return false
+	}
+}
+
+func NewAWS() *AWS {
+	return &AWS{}
+}
--- 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
+}
--- a/pkg/integration/integration.go
+++ b/pkg/integration/integration.go
@@ -16,6 +16,7 @@ package integration
 import (
 	"errors"
 	"fmt"
+	"github.com/k8sgpt-ai/k8sgpt/pkg/integration/aws"

 	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/integration/prometheus"
@@ -47,6 +48,7 @@ type Integration struct {
 var integrations = map[string]IIntegration{
 	"trivy":      trivy.NewTrivy(),
 	"prometheus": prometheus.NewPrometheus(),
+	"aws":        aws.NewAWS(),
 }

 func NewIntegration() *Integration {
--- a/pkg/integration/trivy/analyzer.go
+++ b/pkg/integration/trivy/analyzer.go
@@ -15,9 +15,10 @@ package trivy

 import (
 	"fmt"
-	ctrl "sigs.k8s.io/controller-runtime/pkg/client"
 	"strings"

+	ctrl "sigs.k8s.io/controller-runtime/pkg/client"
+
 	"github.com/aquasecurity/trivy-operator/pkg/apis/aquasecurity/v1alpha1"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/util"
@@ -59,8 +60,8 @@ func (TrivyAnalyzer) analyzeVulnerabilityReports(a common.Analyzer) ([]common.Re
 			}
 		}
 		if len(failures) > 0 {
-			preAnalysis[fmt.Sprintf("%s/%s", report.Labels["trivy-operator.resource.namespace"],
-				report.Labels["trivy-operator.resource.name"])] = common.PreAnalysis{
+			preAnalysis[fmt.Sprintf("%s/%s", report.Namespace,
+				report.Name)] = common.PreAnalysis{
 				TrivyVulnerabilityReport: report,
 				FailureDetails:           failures,
 			}
@@ -122,8 +123,8 @@ func (t TrivyAnalyzer) analyzeConfigAuditReports(a common.Analyzer) ([]common.Re
 		}

 		if len(failures) > 0 {
-			preAnalysis[fmt.Sprintf("%s/%s", report.Labels["trivy-operator.resource.namespace"],
-				report.Labels["trivy-operator.resource.name"])] = common.PreAnalysis{
+			preAnalysis[fmt.Sprintf("%s/%s", report.Namespace,
+				report.Name)] = common.PreAnalysis{
 				TrivyConfigAuditReport: report,
 				FailureDetails:         failures,
 			}
--- a/pkg/kubernetes/apireference_test.go
+++ b/pkg/kubernetes/apireference_test.go
@@ -0,0 +1,106 @@
+/*
+Copyright 2024 The K8sGPT Authors.
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+    http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package kubernetes
+
+import (
+	"testing"
+
+	openapi_v2 "github.com/google/gnostic/openapiv2"
+	"github.com/stretchr/testify/require"
+	"k8s.io/apimachinery/pkg/runtime/schema"
+)
+
+func TestGetApiDocV2(t *testing.T) {
+	k8s := &K8sApiReference{
+		ApiVersion: schema.GroupVersion{
+			Group:   "group.v1",
+			Version: "v1",
+		},
+		OpenapiSchema: &openapi_v2.Document{
+			Definitions: &openapi_v2.Definitions{
+				AdditionalProperties: []*openapi_v2.NamedSchema{
+					{
+						Name: "group.v1.kind",
+						Value: &openapi_v2.Schema{
+							Title: "test",
+							Properties: &openapi_v2.Properties{
+								AdditionalProperties: []*openapi_v2.NamedSchema{
+									{
+										Name: "schema1",
+										Value: &openapi_v2.Schema{
+											Title:       "test",
+											Description: "schema1 description",
+											Type: &openapi_v2.TypeItem{
+												Value: []string{"string"},
+											},
+										},
+									},
+									{
+										Name: "schema2",
+										Value: &openapi_v2.Schema{
+											Items: &openapi_v2.ItemsItem{
+												Schema: []*openapi_v2.Schema{
+													{
+														Title: "random-schema",
+													},
+												},
+											},
+											Title:       "test",
+											XRef:        "xref",
+											Description: "schema2 description",
+											Type: &openapi_v2.TypeItem{
+												Value: []string{"bool"},
+											},
+										},
+									},
+								},
+							},
+						},
+					},
+					{
+						Name: "group",
+					},
+				},
+			},
+		},
+		Kind: "kind",
+	}
+
+	tests := []struct {
+		name           string
+		field          string
+		expectedOutput string
+	}{
+		{
+			name: "empty field",
+		},
+		{
+			name:           "2 schemas",
+			field:          "schema2.schema1",
+			expectedOutput: "",
+		},
+		{
+			name:           "schema1 description",
+			field:          "schema1",
+			expectedOutput: "schema1 description",
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			output := k8s.GetApiDocV2(tt.field)
+			require.Equal(t, tt.expectedOutput, output)
+		})
+	}
+}
--- a/pkg/kubernetes/testdata/kubeconfig
+++ b/pkg/kubernetes/testdata/kubeconfig
@@ -0,0 +1,16 @@
+apiVersion: v1
+clusters:
+- cluster:
+    server: https://192.168.49.2:8443
+  name: minikube
+contexts:
+- context:
+    cluster: minikube
+    namespace: default
+    user: minikube
+  name: minikube
+current-context: minikube
+kind: Config
+preferences: {}
+users:
+- name: minikube
--- a/pkg/server/analyze.go
+++ b/pkg/server/analyze.go
@@ -16,10 +16,6 @@ func (h *handler) Analyze(ctx context.Context, i *schemav1.AnalyzeRequest) (
 		i.Output = "json"
 	}

-	if i.Backend == "" {
-		i.Backend = "openai"
-	}
-
 	if int(i.MaxConcurrency) == 0 {
 		i.MaxConcurrency = 10
 	}
--- a/pkg/server/server.go
+++ b/pkg/server/server.go
@@ -14,17 +14,25 @@ limitations under the License.
 package server

 import (
+	"context"
 	"errors"
 	"fmt"
+	"log"
 	"net"
 	"net/http"
+	"strings"
 	"time"

+	gw "buf.build/gen/go/k8sgpt-ai/k8sgpt/grpc-ecosystem/gateway/v2/schema/v1/server-service/schemav1gateway"
 	rpc "buf.build/gen/go/k8sgpt-ai/k8sgpt/grpc/go/schema/v1/schemav1grpc"
+	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
 	"github.com/prometheus/client_golang/prometheus/promhttp"
 	"go.uber.org/zap"
+	"golang.org/x/net/http2"
+	"golang.org/x/net/http2/h2c"

 	"google.golang.org/grpc"
+	"google.golang.org/grpc/credentials/insecure"
 	"google.golang.org/grpc/reflection"
 )

@@ -39,6 +47,7 @@ type Config struct {
 	Logger        *zap.Logger
 	metricsServer *http.Server
 	listener      net.Listener
+	EnableHttp    bool
 }

 type Health struct {
@@ -58,8 +67,19 @@ func (s *Config) Shutdown() error {
 	return s.listener.Close()
 }

-func (s *Config) Serve() error {
+// grpcHandlerFunc returns an http.Handler that delegates to grpcServer on incoming gRPC
+// connections or otherHandler otherwise.
+func grpcHandlerFunc(grpcServer *grpc.Server, otherHandler http.Handler) http.Handler {
+	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		if r.ProtoMajor == 2 && strings.Contains(r.Header.Get("Content-Type"), "application/grpc") {
+			grpcServer.ServeHTTP(w, r)
+		} else {
+			otherHandler.ServeHTTP(w, r)
+		}
+	})
+}

+func (s *Config) Serve() error {
 	var lis net.Listener
 	var err error
 	address := fmt.Sprintf(":%s", s.Port)
@@ -67,16 +87,36 @@ func (s *Config) Serve() error {
 	if err != nil {
 		return err
 	}
+
 	s.listener = lis
 	s.Logger.Info(fmt.Sprintf("binding api to %s", s.Port))
 	grpcServerUnaryInterceptor := grpc.UnaryInterceptor(logInterceptor(s.Logger))
 	grpcServer := grpc.NewServer(grpcServerUnaryInterceptor)
 	reflection.Register(grpcServer)
 	rpc.RegisterServerServiceServer(grpcServer, s.Handler)
-	if err := grpcServer.Serve(
-		lis,
-	); err != nil && !errors.Is(err, http.ErrServerClosed) {
-		return err
+
+	if s.EnableHttp {
+		s.Logger.Info("enabling rest/http api")
+		gwmux := runtime.NewServeMux()
+		err = gw.RegisterServerServiceHandlerFromEndpoint(context.Background(), gwmux, fmt.Sprintf("localhost:%s", s.Port), []grpc.DialOption{grpc.WithTransportCredentials(insecure.NewCredentials())})
+		if err != nil {
+			log.Fatalln("Failed to register gateway:", err)
+		}
+
+		srv := &http.Server{
+			Addr:    address,
+			Handler: h2c.NewHandler(grpcHandlerFunc(grpcServer, gwmux), &http2.Server{}),
+		}
+
+		if err := srv.Serve(lis); err != nil {
+			return err
+		}
+	} else {
+		if err := grpcServer.Serve(
+			lis,
+		); err != nil && !errors.Is(err, http.ErrServerClosed) {
+			return err
+		}
 	}

 	return nil
--- a/pkg/util/util.go
+++ b/pkg/util/util.go
@@ -23,6 +23,7 @@ import (
 	"fmt"
 	"os"
 	"regexp"
+	"strings"

 	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
 	v1 "k8s.io/api/core/v1"
@@ -216,11 +217,18 @@ func EnsureDirExists(dir string) error {
 }

 func MapToString(m map[string]string) string {
-	var result string
-	for k, v := range m {
-		result += fmt.Sprintf("%s=%s,", k, v)
+	// Handle empty map case
+	if len(m) == 0 {
+		return ""
 	}
-	return result[:len(result)-1]
+
+	var pairs []string
+	for k, v := range m {
+		pairs = append(pairs, fmt.Sprintf("%s=%s", k, v))
+	}
+
+	// Efficient string joining
+	return strings.Join(pairs, ",")
 }

 func LabelsIncludeAny(predefinedSelector, Labels map[string]string) bool {
--- a/pkg/util/util_test.go
+++ b/pkg/util/util_test.go
@@ -0,0 +1,523 @@
+/*
+Copyright 2024 The K8sGPT Authors.
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+    http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package util
+
+import (
+	"testing"
+
+	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
+	"github.com/stretchr/testify/require"
+	admissionregistrationv1 "k8s.io/api/admissionregistration/v1"
+	appsv1 "k8s.io/api/apps/v1"
+	v1 "k8s.io/api/core/v1"
+	networkingv1 "k8s.io/api/networking/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/client-go/kubernetes/fake"
+)
+
+func TestSliceContainsString(t *testing.T) {
+	tests := []struct {
+		slice    []string
+		s        string
+		expected bool
+	}{
+		{
+			expected: false,
+		},
+		{
+			slice:    []string{"temp", "value"},
+			s:        "value",
+			expected: true,
+		},
+	}
+	for _, tt := range tests {
+		tt := tt
+		t.Run(tt.s, func(t *testing.T) {
+			require.Equal(t, tt.expected, SliceContainsString(tt.slice, tt.s))
+		})
+	}
+}
+
+func TestGetParent(t *testing.T) {
+	ownerName := "test-name"
+	namespace := "test"
+	clientset := fake.NewSimpleClientset(
+		&appsv1.ReplicaSet{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      ownerName,
+				Namespace: namespace,
+			},
+		},
+		&appsv1.Deployment{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      ownerName,
+				Namespace: namespace,
+			},
+		},
+		&appsv1.StatefulSet{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      ownerName,
+				Namespace: namespace,
+			},
+		},
+		&appsv1.DaemonSet{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      ownerName,
+				Namespace: namespace,
+			},
+		},
+		&networkingv1.Ingress{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      ownerName,
+				Namespace: namespace,
+			},
+		},
+		&admissionregistrationv1.MutatingWebhookConfiguration{
+			ObjectMeta: metav1.ObjectMeta{
+				Name: ownerName,
+			},
+		},
+		&admissionregistrationv1.ValidatingWebhookConfiguration{
+			ObjectMeta: metav1.ObjectMeta{
+				Name: ownerName,
+			},
+		},
+	)
+	kubeClient := kubernetes.Client{
+		Client: clientset,
+	}
+
+	tests := []struct {
+		name           string
+		kind           string
+		expectedOutput string
+	}{
+		{
+			kind:           "Unknown",
+			expectedOutput: ownerName,
+		},
+		{
+			kind: "ReplicaSet",
+		},
+		{
+			kind:           "ReplicaSet",
+			name:           ownerName,
+			expectedOutput: "ReplicaSet/test-name",
+		},
+		{
+			kind: "Deployment",
+		},
+		{
+			kind:           "Deployment",
+			name:           ownerName,
+			expectedOutput: "Deployment/test-name",
+		},
+		{
+			kind: "StatefulSet",
+		},
+		{
+			kind:           "StatefulSet",
+			name:           ownerName,
+			expectedOutput: "StatefulSet/test-name",
+		},
+		{
+			kind: "DaemonSet",
+		},
+		{
+			kind:           "DaemonSet",
+			name:           ownerName,
+			expectedOutput: "DaemonSet/test-name",
+		},
+		{
+			kind: "Ingress",
+		},
+		{
+			kind:           "Ingress",
+			name:           ownerName,
+			expectedOutput: "Ingress/test-name",
+		},
+		{
+			kind: "MutatingWebhookConfiguration",
+		},
+		{
+			kind:           "MutatingWebhookConfiguration",
+			name:           ownerName,
+			expectedOutput: "MutatingWebhook/test-name",
+		},
+		{
+			kind: "ValidatingWebhookConfiguration",
+		},
+		{
+			kind:           "ValidatingWebhookConfiguration",
+			name:           ownerName,
+			expectedOutput: "ValidatingWebhook/test-name",
+		},
+	}
+	for _, tt := range tests {
+		tt := tt
+		t.Run(tt.kind, func(t *testing.T) {
+			meta := metav1.ObjectMeta{
+				Namespace: namespace,
+				Name:      ownerName,
+				OwnerReferences: []metav1.OwnerReference{
+					{
+						Kind: tt.kind,
+						Name: tt.name,
+					},
+				},
+			}
+			output, ok := GetParent(&kubeClient, meta)
+			require.Equal(t, tt.expectedOutput, output)
+			require.Equal(t, false, ok)
+		})
+	}
+}
+
+func TestRemoveDuplicates(t *testing.T) {
+	tests := []struct {
+		name               string
+		slice              []string
+		expectedDuplicates []string
+	}{
+		{
+			name:               "all empty",
+			expectedDuplicates: []string{},
+		},
+		{
+			name:               "all unique",
+			slice:              []string{"temp", "value"},
+			expectedDuplicates: []string{},
+		},
+		{
+			name:               "slice not unique",
+			slice:              []string{"temp", "mango", "mango"},
+			expectedDuplicates: []string{"mango"},
+		},
+	}
+	for _, tt := range tests {
+		tt := tt
+		t.Run(tt.name, func(t *testing.T) {
+			_, duplicates := RemoveDuplicates(tt.slice)
+			require.Equal(t, tt.expectedDuplicates, duplicates)
+		})
+	}
+}
+
+func TestSliceDiff(t *testing.T) {
+	tests := []struct {
+		name         string
+		source       []string
+		dest         []string
+		expectedDiff []string
+	}{
+		{
+			name: "all empty",
+		},
+		{
+			name:         "non empty",
+			source:       []string{"temp"},
+			dest:         []string{"random"},
+			expectedDiff: []string{"temp"},
+		},
+		{
+			name:   "no diff",
+			source: []string{"temp", "random"},
+			dest:   []string{"random", "temp"},
+		},
+	}
+	for _, tt := range tests {
+		tt := tt
+		t.Run(tt.name, func(t *testing.T) {
+			require.Equal(t, tt.expectedDiff, SliceDiff(tt.source, tt.dest))
+		})
+	}
+}
+
+func TestReplaceIfMatch(t *testing.T) {
+	tests := []struct {
+		text           string
+		pattern        string
+		replacement    string
+		expectedOutput string
+	}{
+		{
+			text:           "",
+			expectedOutput: "",
+		},
+		{
+			text:           "some value",
+			pattern:        "new",
+			replacement:    "latest",
+			expectedOutput: "some value",
+		},
+		{
+			text:           "new value",
+			pattern:        "value",
+			replacement:    "day",
+			expectedOutput: "new day",
+		},
+	}
+	for _, tt := range tests {
+		tt := tt
+		t.Run(tt.text, func(t *testing.T) {
+			require.Equal(t, tt.expectedOutput, ReplaceIfMatch(tt.text, tt.pattern, tt.replacement))
+		})
+	}
+}
+
+func TestGetCacheKey(t *testing.T) {
+	tests := []struct {
+		provider       string
+		language       string
+		sEnc           string
+		expectedOutput string
+	}{
+		{
+			expectedOutput: "d8156bae0c4243d3742fc4e9774d8aceabe0410249d720c855f98afc88ff846c",
+		},
+		{
+			provider:       "provider",
+			language:       "english",
+			sEnc:           "encoding",
+			expectedOutput: "39415cc324b1553b93e80e46049e4e4dbb752dc7d0424b2c6ac96d745c6392aa",
+		},
+	}
+	for _, tt := range tests {
+		tt := tt
+		t.Run(tt.language, func(t *testing.T) {
+			require.Equal(t, tt.expectedOutput, GetCacheKey(tt.provider, tt.language, tt.sEnc))
+		})
+	}
+}
+
+func TestGetPodListByLabels(t *testing.T) {
+	namespace1 := "test1"
+	namespace2 := "test2"
+	clientset := fake.NewSimpleClientset(
+		&v1.Pod{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      "Pod1",
+				Namespace: namespace1,
+				Labels: map[string]string{
+					"Name":      "Pod1",
+					"Namespace": namespace1,
+				},
+			},
+		},
+		&v1.Pod{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      "Pod2",
+				Namespace: namespace2,
+				Labels: map[string]string{
+					"Name":      "Pod2",
+					"Namespace": namespace2,
+				},
+			},
+		},
+		&v1.Pod{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      "Pod3",
+				Namespace: namespace1,
+				Labels: map[string]string{
+					"Name":      "Pod3",
+					"Namespace": namespace1,
+				},
+			},
+		},
+		&v1.Pod{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      "Pod4",
+				Namespace: namespace2,
+				Labels: map[string]string{
+					"Name":      "Pod4",
+					"Namespace": namespace2,
+				},
+			},
+		},
+	)
+
+	tests := []struct {
+		name        string
+		namespace   string
+		labels      map[string]string
+		expectedLen int
+		expectedErr string
+	}{
+		{
+			name:      "Name is Pod1",
+			namespace: namespace1,
+			labels: map[string]string{
+				"Name": "Pod1",
+			},
+			expectedLen: 1,
+		},
+		{
+			name:      "Name is Pod2 in namespace1",
+			namespace: namespace1,
+			labels: map[string]string{
+				"Name": "Pod2",
+			},
+			expectedLen: 0,
+		},
+		{
+			name:      "Name is Pod2 in namespace 2",
+			namespace: namespace2,
+			labels: map[string]string{
+				"Name": "Pod2",
+			},
+			expectedLen: 1,
+		},
+		{
+			name:      "All pods with namespace2 label in namespace1",
+			namespace: namespace1,
+			labels: map[string]string{
+				"Namespace": namespace2,
+			},
+			expectedLen: 0,
+		},
+		{
+			name:      "All pods with namespace2 label in namespace2",
+			namespace: namespace2,
+			labels: map[string]string{
+				"Namespace": namespace2,
+			},
+			expectedLen: 2,
+		},
+	}
+	for _, tt := range tests {
+		tt := tt
+		t.Run(tt.name, func(t *testing.T) {
+			pl, err := GetPodListByLabels(clientset, tt.namespace, tt.labels)
+			if tt.expectedErr == "" {
+				require.NoError(t, err)
+				require.Equal(t, tt.expectedLen, len(pl.Items))
+			} else {
+				require.ErrorContains(t, err, tt.expectedErr)
+				require.Nil(t, pl)
+			}
+		})
+	}
+}
+func TestFileExists(t *testing.T) {
+	tests := []struct {
+		filePath  string
+		isPresent bool
+		err       string
+	}{
+		{
+			filePath:  "",
+			isPresent: false,
+		},
+		{
+			filePath:  "./util.go",
+			isPresent: true,
+		},
+	}
+	for _, tt := range tests {
+		tt := tt
+		t.Run(tt.filePath, func(t *testing.T) {
+			isPresent, err := FileExists(tt.filePath)
+			if tt.err == "" {
+				require.NoError(t, err)
+			} else {
+				require.ErrorContains(t, err, tt.err)
+			}
+			require.Equal(t, tt.isPresent, isPresent)
+		})
+	}
+}
+
+func TestEnsureDirExists(t *testing.T) {
+	tests := []struct {
+		dir string
+		err string
+	}{
+		{
+			dir: "",
+			err: "mkdir : no such file or directory",
+		},
+		{
+			dir: "./",
+		},
+	}
+	for _, tt := range tests {
+		tt := tt
+		t.Run(tt.dir, func(t *testing.T) {
+			err := EnsureDirExists(tt.dir)
+			if tt.err == "" {
+				require.NoError(t, err)
+			} else {
+				require.ErrorContains(t, err, tt.err)
+			}
+		})
+	}
+}
+
+func TestMapToString(t *testing.T) {
+	tests := []struct {
+		name   string
+		m      map[string]string
+		output string
+	}{
+		{
+			name: "empty map",
+			m:    map[string]string{},
+		},
+		{
+			name: "non-empty map",
+			m: map[string]string{
+				"key": "value",
+			},
+			output: "key=value",
+		},
+	}
+	for _, tt := range tests {
+		tt := tt
+		t.Run(tt.name, func(t *testing.T) {
+			require.Equal(t, tt.output, MapToString(tt.m))
+		})
+	}
+}
+
+func TestLabelsIncludeAny(t *testing.T) {
+	tests := []struct {
+		name string
+		m    map[string]string
+		p    map[string]string
+		ok   bool
+	}{
+		{
+			name: "empty map",
+			m:    map[string]string{},
+			p:    map[string]string{},
+			ok:   false,
+		},
+		{
+			name: "non-empty map",
+			m: map[string]string{
+				"key": "value",
+			},
+			p: map[string]string{
+				"key": "value",
+			},
+			ok: true,
+		},
+	}
+	for _, tt := range tests {
+		tt := tt
+		t.Run(tt.name, func(t *testing.T) {
+			require.Equal(t, tt.ok, LabelsIncludeAny(tt.p, tt.m))
+		})
+	}
+}
--- a/renovate.json
+++ b/renovate.json
@@ -12,8 +12,36 @@
  ],
  "automerge": true,
  "automergeType": "pr",
+  "schedule": [
+    "at any time"
+  ],
  "platformAutomerge": true,
  "packageRules": [
+    {
+      "matchPackageNames": ["^github.com/Azure/azure-sdk-for-go/"],
+      "enabled": true,
+      "group": "azure-group"
+    },
+    {
+      "matchPackageNames": ["^github.com/prometheus/"],
+      "enabled": true,
+      "group": "prometheus-group"
+    },
+    {
+      "matchPackageNames": ["^k8s.io/", "^sigs.k8s.io/"],
+      "enabled": true,
+      "groupName": "kubernetes-group"
+    },
+    {
+      "matchPackageNames": ["^github.com/golang/","^golang.org"],
+      "enabled": true,
+      "group": "golang-group"
+    },
+    {
+      "matchPackageNames": ["^github.com/"],
+      "enabled": true,
+      "group": "github arbitrary dependencies"
+    },
    {
      "description": "Exclude retracted cohere-go versions: https://github.com/renovatebot/renovate/issues/13012",
      "matchPackageNames": ["github.com/cohere-ai/cohere-go"],