chore: resolved mod

Signed-off-by: Alex Jones <alexsimonjones@gmail.com>

.github/workflows/build_container.yaml

@@ -96,7 +96,7 @@ jobs:
           outputs: type=docker,dest=/tmp/${{ env.IMAGE_NAME }}-image.tar
 
       - name: Upload image as artifact
-        uses: actions/upload-artifact@5d5d22a31266ced268874388b861e4b58bb5c2f3 # v4
+        uses: actions/upload-artifact@1eb3cb2b3e0f29609092a73eb033bb759a334595 # v4
         with:
           name: ${{ env.IMAGE_NAME }}-image.tar
           path: /tmp/${{ env.IMAGE_NAME }}-image.tar

.github/workflows/golangci_lint.yaml

@@ -2,7 +2,7 @@ name: Run golangci-lint
 
 on:
   pull_request:
-    branches: [main]
+    branches: [ main ]
 
 jobs:
   golangci-lint:
@@ -12,9 +12,7 @@ jobs:
         uses: actions/checkout@b4ffde65f46336ab88eb53be808477a3936bae11 # v4
 
       - name: golangci-lint
-        uses: reviewdog/action-golangci-lint@8e1117c7d327bbfb1eb7ec8dc2d895d13e6e17c3 # v2
+        uses: reviewdog/action-golangci-lint@24d4af2fc93f5b2b296229e8b0c0f658d25707af # v2
         with:
           github_token: ${{ secrets.GITHUB_TOKEN }}
           reporter: github-pr-check
-          golangci_lint_flags: "--timeout=120s"
-          level: warning

.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@c7f031d9249a826a082ea14c79d3b686a51d485a # v0.15.3
       - name: Run GoReleaser
         uses: goreleaser/goreleaser-action@7ec5c2b0c6cdda6e8bbb49444bc797dd33d74dd8 # v5
         with:
@@ -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@c7f031d9249a826a082ea14c79d3b686a51d485a # v0.15.3
         with:
           image: ${{ env.IMAGE_TAG }}
           artifact-name: sbom-${{ env.IMAGE_NAME }}

.release-please-manifest.json

@@ -1 +1 @@
-{".":"0.3.27"}
+{".":"0.3.26"}

CHANGELOG.md

@@ -1,62 +1,5 @@
 # Changelog
 
-## [0.3.27](https://github.com/k8sgpt-ai/k8sgpt/compare/v0.3.26...v0.3.27) (2024-02-15)
-
-
-### Features
-
-* add huggingface provider ([#893](https://github.com/k8sgpt-ai/k8sgpt/issues/893)) ([2fd476e](https://github.com/k8sgpt-ai/k8sgpt/commit/2fd476e12624e30570c0819594f2668f720381d6))
-* added FailedMount event reason to get the failure ([#883](https://github.com/k8sgpt-ai/k8sgpt/issues/883)) ([78126b2](https://github.com/k8sgpt-ai/k8sgpt/commit/78126b2328c1b3f81a269d203e86128104050010))
-* enables remote custom analyzers ([#906](https://github.com/k8sgpt-ai/k8sgpt/issues/906)) ([c8c9dbf](https://github.com/k8sgpt-ai/k8sgpt/commit/c8c9dbfadc72a193ab9f3431d02d50ac5ab5d071))
-
-
-### Bug Fixes
-
-* **deps:** update k8s.io/utils digest to e7106e6 ([#897](https://github.com/k8sgpt-ai/k8sgpt/issues/897)) ([28c4c57](https://github.com/k8sgpt-ai/k8sgpt/commit/28c4c57e4566b9b888a5633090ccb70875d30106))
-* **deps:** update module buf.build/gen/go/k8sgpt-ai/k8sgpt/grpc/go to v1.3.0-20240128172516-6bf6a55ff115.2 ([#899](https://github.com/k8sgpt-ai/k8sgpt/issues/899)) ([e3eee6d](https://github.com/k8sgpt-ai/k8sgpt/commit/e3eee6d9566a59fd62e6bb804257b1383f75e3ef))
-* **deps:** update module cloud.google.com/go/storage to v1.37.0 ([#934](https://github.com/k8sgpt-ai/k8sgpt/issues/934)) ([3d2554b](https://github.com/k8sgpt-ai/k8sgpt/commit/3d2554b9cd8817b24cf8858a107420d6d8424aa4))
-* **deps:** update module github.com/aws/aws-sdk-go to v1.49.21 ([#868](https://github.com/k8sgpt-ai/k8sgpt/issues/868)) ([88002e7](https://github.com/k8sgpt-ai/k8sgpt/commit/88002e7e8c3e9c71365c44e136a6f1a8d35e1744))
-* **deps:** update module github.com/aws/aws-sdk-go to v1.50.2 ([#887](https://github.com/k8sgpt-ai/k8sgpt/issues/887)) ([817d9cf](https://github.com/k8sgpt-ai/k8sgpt/commit/817d9cf754d307d374befc0d57919eb7a0183aaf))
-* **deps:** update module github.com/azure/azure-sdk-for-go/sdk/azidentity to v1.5.1 ([#939](https://github.com/k8sgpt-ai/k8sgpt/issues/939)) ([ce7c955](https://github.com/k8sgpt-ai/k8sgpt/commit/ce7c9551bcb1a8b24922a1eb062605bbfeec7929))
-* **deps:** update module github.com/azure/azure-sdk-for-go/sdk/storage/azblob to v1.3.0 ([#952](https://github.com/k8sgpt-ai/k8sgpt/issues/952)) ([fea2ed1](https://github.com/k8sgpt-ai/k8sgpt/commit/fea2ed1fff5fb5a46d6abc2feb72e1e1adf3b69b))
-* **deps:** update module github.com/google/generative-ai-go to v0.7.0 ([#940](https://github.com/k8sgpt-ai/k8sgpt/issues/940)) ([3c8d9d4](https://github.com/k8sgpt-ai/k8sgpt/commit/3c8d9d42e573f27185a1572d1bc06f8af87f3a0b))
-* **deps:** update module github.com/prometheus/prometheus to v2 ([#863](https://github.com/k8sgpt-ai/k8sgpt/issues/863)) ([a253af2](https://github.com/k8sgpt-ai/k8sgpt/commit/a253af23b601b23179be5019fbb832a41423cdae))
-* **deps:** update module github.com/pterm/pterm to v0.12.75 ([#881](https://github.com/k8sgpt-ai/k8sgpt/issues/881)) ([e7d690a](https://github.com/k8sgpt-ai/k8sgpt/commit/e7d690afd12cb71d7b344ba92bf059ae18a993c8))
-* **deps:** update module github.com/pterm/pterm to v0.12.78 ([#890](https://github.com/k8sgpt-ai/k8sgpt/issues/890)) ([f9c1b90](https://github.com/k8sgpt-ai/k8sgpt/commit/f9c1b903385978be56f9c4bc87089bd1c761bbea))
-* **deps:** update module github.com/pterm/pterm to v0.12.79 ([#943](https://github.com/k8sgpt-ai/k8sgpt/issues/943)) ([bfbb5c7](https://github.com/k8sgpt-ai/k8sgpt/commit/bfbb5c7e03cad144f6037c7233ffc0817fd403e4))
-* **deps:** update module github.com/sashabaranov/go-openai to v1.18.1 ([#871](https://github.com/k8sgpt-ai/k8sgpt/issues/871)) ([6c62c1a](https://github.com/k8sgpt-ai/k8sgpt/commit/6c62c1a0fcd38cf9de8a99cda6f37b221740b9c8))
-* **deps:** update module github.com/sashabaranov/go-openai to v1.18.2 ([#874](https://github.com/k8sgpt-ai/k8sgpt/issues/874)) ([4de1bbd](https://github.com/k8sgpt-ai/k8sgpt/commit/4de1bbd6f72ca83d46ce5955bac50dffc99af03d))
-* **deps:** update module github.com/sashabaranov/go-openai to v1.19.2 ([#886](https://github.com/k8sgpt-ai/k8sgpt/issues/886)) ([c601972](https://github.com/k8sgpt-ai/k8sgpt/commit/c6019728aea837884620e0b4894568802a948a6e))
-* **deps:** update module github.com/sashabaranov/go-openai to v1.19.3 ([#937](https://github.com/k8sgpt-ai/k8sgpt/issues/937)) ([f2eb1ef](https://github.com/k8sgpt-ai/k8sgpt/commit/f2eb1ef5334877fd3a26dda8c92023f831ea857e))
-* **deps:** update module golang.org/x/term to v0.17.0 ([#941](https://github.com/k8sgpt-ai/k8sgpt/issues/941)) ([4e57088](https://github.com/k8sgpt-ai/k8sgpt/commit/4e57088a0137767a42c778a59ff07fff04c04289))
-* **deps:** update module google.golang.org/api to v0.157.0 ([#860](https://github.com/k8sgpt-ai/k8sgpt/issues/860)) ([72e08ef](https://github.com/k8sgpt-ai/k8sgpt/commit/72e08efff1fc501dfcba791c9d940e575f3e2395))
-* **deps:** update module google.golang.org/api to v0.164.0 ([#953](https://github.com/k8sgpt-ai/k8sgpt/issues/953)) ([29b482f](https://github.com/k8sgpt-ai/k8sgpt/commit/29b482f5978795fa8db729030bd75803e2e61f95))
-* **deps:** update module google.golang.org/grpc to v1.61.1 ([#954](https://github.com/k8sgpt-ai/k8sgpt/issues/954)) ([9c1f1b8](https://github.com/k8sgpt-ai/k8sgpt/commit/9c1f1b8804a26f549379efe637d0bedb8e2cb890))
-* **deps:** update module gopkg.in/yaml.v2 to v3 ([#866](https://github.com/k8sgpt-ai/k8sgpt/issues/866)) ([81d6604](https://github.com/k8sgpt-ai/k8sgpt/commit/81d660447d236cd03b75866871bb69f2c77c5c66))
-* **deps:** update module gopkg.in/yaml.v2 to v3 ([#875](https://github.com/k8sgpt-ai/k8sgpt/issues/875)) ([1f371e2](https://github.com/k8sgpt-ai/k8sgpt/commit/1f371e2807c47dbb4613bf873ec67a77e8e6c80c))
-* **deps:** update module gopkg.in/yaml.v2 to v3 ([#956](https://github.com/k8sgpt-ai/k8sgpt/issues/956)) ([d9fe744](https://github.com/k8sgpt-ai/k8sgpt/commit/d9fe7446af428209610adc83ec17cf50491a5a47))
-* lint errors ([#923](https://github.com/k8sgpt-ai/k8sgpt/issues/923)) ([3415031](https://github.com/k8sgpt-ai/k8sgpt/commit/3415031006bb5899019e68d33ac6083d03ef864b))
-* typo in httproute files name ([#877](https://github.com/k8sgpt-ai/k8sgpt/issues/877)) ([cdbeb14](https://github.com/k8sgpt-ai/k8sgpt/commit/cdbeb146a28ebc21ac2c4d27e977b1771f9290b4))
-* unused variable failure warning in webhooks file ([#916](https://github.com/k8sgpt-ai/k8sgpt/issues/916)) ([3f0964a](https://github.com/k8sgpt-ai/k8sgpt/commit/3f0964ad385390f53516904219fbfc47b989d31f))
-
-
-### Other
-
-* **deps:** update actions/upload-artifact digest to 26f96df ([#888](https://github.com/k8sgpt-ai/k8sgpt/issues/888)) ([483a9da](https://github.com/k8sgpt-ai/k8sgpt/commit/483a9dad103ad1af82491dc1d5e0a39bb4865a1b))
-* **deps:** update actions/upload-artifact digest to 5d5d22a ([#925](https://github.com/k8sgpt-ai/k8sgpt/issues/925)) ([070aa7f](https://github.com/k8sgpt-ai/k8sgpt/commit/070aa7fdd0982c0c7f02a1da9e6797d5efaa5586))
-* **deps:** update actions/upload-artifact digest to 694cdab ([#880](https://github.com/k8sgpt-ai/k8sgpt/issues/880)) ([3cf18e7](https://github.com/k8sgpt-ai/k8sgpt/commit/3cf18e783edb341b7bdd6aa20dbcce11971fa241))
-* **deps:** update anchore/sbom-action action to v0.15.4 ([#879](https://github.com/k8sgpt-ai/k8sgpt/issues/879)) ([d213399](https://github.com/k8sgpt-ai/k8sgpt/commit/d2133991617697b13b8846f2acb3a3bb6cebb160))
-* **deps:** update anchore/sbom-action action to v0.15.5 ([#885](https://github.com/k8sgpt-ai/k8sgpt/issues/885)) ([60853fe](https://github.com/k8sgpt-ai/k8sgpt/commit/60853fe4eb8de7a1fdbaea388c3d2d6205e273a6))
-* **deps:** update anchore/sbom-action action to v0.15.8 ([#926](https://github.com/k8sgpt-ai/k8sgpt/issues/926)) ([f61c3e2](https://github.com/k8sgpt-ai/k8sgpt/commit/f61c3e228c69fa160735ddb2c1347720112b738f))
-* **deps:** update golang docker tag to v1.22 ([#931](https://github.com/k8sgpt-ai/k8sgpt/issues/931)) ([37228d8](https://github.com/k8sgpt-ai/k8sgpt/commit/37228d88e357c66c5574559ae27a52fdf28418b8))
-* **deps:** update reviewdog/action-golangci-lint digest to 8e1117c ([#915](https://github.com/k8sgpt-ai/k8sgpt/issues/915)) ([599be33](https://github.com/k8sgpt-ai/k8sgpt/commit/599be33f38ad1fd688b8e7824102a7944d516435))
-* **deps:** update reviewdog/action-golangci-lint digest to f016e79 ([#714](https://github.com/k8sgpt-ai/k8sgpt/issues/714)) ([335616c](https://github.com/k8sgpt-ai/k8sgpt/commit/335616c20f7f8d9fefab4976d986a8d3b4867111))
-* grpc update ([#938](https://github.com/k8sgpt-ai/k8sgpt/issues/938)) ([bbf61f5](https://github.com/k8sgpt-ai/k8sgpt/commit/bbf61f53d4fb9244b5a79ae953370296ca9fd44b))
-* improve codebase and doc quality ([#922](https://github.com/k8sgpt-ai/k8sgpt/issues/922)) ([d97dea2](https://github.com/k8sgpt-ai/k8sgpt/commit/d97dea289681cd061ca0796208c50720bdb08914))
-* linting improvements and catching false positives ([#882](https://github.com/k8sgpt-ai/k8sgpt/issues/882)) ([2effbb3](https://github.com/k8sgpt-ai/k8sgpt/commit/2effbb345ad1c2771ec798e06ccde68d3253b4bc))
-* set correct license during package build ([#872](https://github.com/k8sgpt-ai/k8sgpt/issues/872)) ([42be51b](https://github.com/k8sgpt-ai/k8sgpt/commit/42be51bc8f625a35b1435c461d9a32c3c4905f1c))
-* updated deps ([#951](https://github.com/k8sgpt-ai/k8sgpt/issues/951)) ([015bccf](https://github.com/k8sgpt-ai/k8sgpt/commit/015bccfc2eae587e0ade371211404f5af4c37d27))
-
 ## [0.3.26](https://github.com/k8sgpt-ai/k8sgpt/compare/v0.3.25...v0.3.26) (2024-01-14)
 
 

README.md

@@ -8,12 +8,9 @@
 ![GitHub Workflow Status](https://img.shields.io/github/actions/workflow/status/k8sgpt-ai/k8sgpt/release.yaml)
 ![GitHub release (latest by date)](https://img.shields.io/github/v/release/k8sgpt-ai/k8sgpt)
 [![OpenSSF Best Practices](https://bestpractices.coreinfrastructure.org/projects/7272/badge)](https://bestpractices.coreinfrastructure.org/projects/7272)
-[![Link to documentation](https://img.shields.io/static/v1?label=%F0%9F%93%96&message=Documentation&color=blue)](https://docs.k8sgpt.ai/)  
+[![Link to documentation](https://img.shields.io/static/v1?label=%F0%9F%93%96&message=Documentation&color=blue)](https://docs.k8sgpt.ai/)
 [![FOSSA Status](https://app.fossa.com/api/projects/git%2Bgithub.com%2Fk8sgpt-ai%2Fk8sgpt.svg?type=shield)](https://app.fossa.com/projects/git%2Bgithub.com%2Fk8sgpt-ai%2Fk8sgpt?ref=badge_shield)
-[![License](https://img.shields.io/badge/License-Apache_2.0-blue.svg)](https://opensource.org/licenses/Apache-2.0)
-[![Go version](https://img.shields.io/github/go-mod/go-version/k8sgpt-ai/k8sgpt.svg)](https://github.com/k8sgpt-ai/k8sgpt)
 [![codecov](https://codecov.io/github/k8sgpt-ai/k8sgpt/graph/badge.svg?token=ZLR7NG8URE)](https://codecov.io/github/k8sgpt-ai/k8sgpt)
-![GitHub last commit (branch)](https://img.shields.io/github/last-commit/k8sgpt-ai/k8sgpt/main)  
 
 `k8sgpt` is a tool for scanning your Kubernetes clusters, diagnosing, and triaging issues in simple English.
 
@@ -41,7 +38,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.26/k8sgpt_386.rpm
   sudo rpm -ivh k8sgpt_386.rpm
   ```
   <!---x-release-please-end-->
@@ -50,7 +47,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.26/k8sgpt_amd64.rpm
   sudo rpm -ivh -i k8sgpt_amd64.rpm
   ```
   <!---x-release-please-end-->
@@ -62,7 +59,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.26/k8sgpt_386.deb
   sudo dpkg -i k8sgpt_386.deb
   ```
   <!---x-release-please-end-->
@@ -70,7 +67,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.26/k8sgpt_amd64.deb
   sudo dpkg -i k8sgpt_amd64.deb
   ```
   <!---x-release-please-end-->
@@ -83,14 +80,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.26/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.26/k8sgpt_amd64.apk
   apk add k8sgpt_amd64.apk
   ```
   <!---x-release-please-end-->x
@@ -312,7 +309,6 @@ Unused:
 > amazonbedrock
 > amazonsagemaker
 > google
-> huggingface
 > noopai
 ```
 
@@ -459,33 +455,6 @@ k8sgpt cache remove
 ```
 </details>
 
-<details>
-<summary> Custom Analyzers</summary>
-
-There may be scenarios where you wish to write your own analyzer in a language of your choice.
-K8sGPT now supports the ability to do so by abiding by the [schema](https://github.com/k8sgpt-ai/schemas/blob/main/protobuf/schema/v1/analyzer.proto) and serving the analyzer for consumption.
-To do so, define the analyzer within the K8sGPT configuration and it will add it into the scanning process.
-In addition to this you will need to enable the following flag on analysis:
-```
-k8sgpt analyze --custom-analysis
-```
-
-Here is an example local host analyzer in [Rust](https://github.com/k8sgpt-ai/host-analyzer)
-When this is run on `localhost:8080` the K8sGPT config can pick it up with the following additions:
-
-```
-custom_analyzers:
-  - name: host-analyzer
-    connection:
-      url: localhost
-      port: 8080
-```
-
-This now gives the ability to pass through hostOS information ( from this analyzer example ) to K8sGPT to use as context with normal analysis.
-
-_See the docs on how to write a custom analyzer_
-
-</details>
 
 ## Documentation
 

cmd/analyze/analyze.go

@@ -37,7 +37,6 @@ var (
 	maxConcurrency  int
 	withDoc         bool
 	interactiveMode bool
-	customAnalysis  bool
 )
 
 // AnalyzeCmd represents the problems command
@@ -66,9 +65,6 @@ var AnalyzeCmd = &cobra.Command{
 		}
 		defer config.Close()
 
-		if customAnalysis {
-			config.RunCustomAnalysis()
-		}
 		config.RunAnalysis()
 
 		if explain {
@@ -135,7 +131,4 @@ func init() {
 	AnalyzeCmd.Flags().BoolVarP(&withDoc, "with-doc", "d", false, "Give me the official documentation of the involved field")
 	// interactive mode flag
 	AnalyzeCmd.Flags().BoolVarP(&interactiveMode, "interactive", "i", false, "Enable interactive mode that allows further conversation with LLM about the problem. Works only with --explain flag")
-	// custom analysis flag
-	AnalyzeCmd.Flags().BoolVarP(&customAnalysis, "custom-analysis", "z", false, "Enable custom analyzers")
-
 }

cmd/cache/add.go

@@ -24,8 +24,7 @@ import (
 )
 
 var (
-	region string
-	//nolint:unused
+	region         string
 	bucketName     string
 	storageAccount string
 	containerName  string

cmd/generate/generate.go

@@ -24,8 +24,7 @@ import (
 )
 
 var (
-	backend     string
-	backendType string
+	backend string
 )
 
 // generateCmd represents the auth command
@@ -35,7 +34,7 @@ var GenerateCmd = &cobra.Command{
 	Long:  `Opens your browser to generate a key for your chosen backend.`,
 	Run: func(cmd *cobra.Command, args []string) {
 
-		backendType = viper.GetString("backend_type")
+		backendType := viper.GetString("backend_type")
 		if backendType == "" {
 			// Set the default backend
 			backend = "openai"

cmd/serve/serve.go

@@ -33,6 +33,7 @@ var (
 	port        string
 	metricsPort string
 	backend     string
+	enableHttp  bool
 )
 
 var ServeCmd = &cobra.Command{
@@ -120,17 +121,13 @@ var ServeCmd = &cobra.Command{
 			color.Red("failed to create logger: %v", err)
 			os.Exit(1)
 		}
-		defer func() {
-			if err := logger.Sync(); err != nil {
-				color.Red("failed to sync logger: %v", err)
-				os.Exit(1)
-			}
-		}()
+		defer logger.Sync()
 
 		server := k8sgptserver.Config{
 			Backend:     aiProvider.Name,
 			Port:        port,
 			MetricsPort: metricsPort,
+			EnableHttp:  enableHttp,
 			Token:       aiProvider.Password,
 			Logger:      logger,
 		}
@@ -158,4 +155,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", "h", false, "Enable REST/http using gppc-gateway")
 }

container/Dockerfile

@@ -9,7 +9,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-FROM golang:1.22-alpine3.19 AS builder
+FROM golang:1.21-alpine3.19 AS builder
 
 ENV CGO_ENABLED=0
 ARG VERSION

go.mod

@@ -7,12 +7,13 @@ 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/prometheus/prometheus v1.8.2-0.20211119115433-692a54649ed7
+	github.com/sashabaranov/go-openai v1.18.2
 	github.com/schollz/progressbar/v3 v3.14.1
 	github.com/spf13/cobra v1.8.0
 	github.com/spf13/viper v1.18.2
 	github.com/stretchr/testify v1.8.4
-	golang.org/x/term v0.17.0
+	golang.org/x/term v0.16.0
 	helm.sh/helm/v3 v3.13.3
 	k8s.io/api v0.28.4
 	k8s.io/apimachinery v0.28.4
@@ -24,19 +25,18 @@ require (
 require github.com/adrg/xdg v0.4.0
 
 require (
-	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
-	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
+	buf.build/gen/go/k8sgpt-ai/k8sgpt/grpc/go v1.3.0-20240208090903-d4147b284845.2
+	buf.build/gen/go/k8sgpt-ai/k8sgpt/protocolbuffers/go v1.32.0-20240208090903-d4147b284845.1
+	cloud.google.com/go/storage v1.36.0
+	github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.4.0
+	github.com/Azure/azure-sdk-for-go/sdk/storage/azblob v1.2.1
+	github.com/aws/aws-sdk-go v1.49.21
 	github.com/cohere-ai/cohere-go v0.2.0
-	github.com/google/generative-ai-go v0.7.0
-	github.com/hupe1980/go-huggingface v0.0.15
+	github.com/google/generative-ai-go v0.5.0
+	github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.1
 	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
+	github.com/pterm/pterm v0.12.74
+	google.golang.org/api v0.155.0
 	gopkg.in/yaml.v2 v2.4.0
 	sigs.k8s.io/controller-runtime v0.16.3
 	sigs.k8s.io/gateway-api v1.0.0
@@ -46,17 +46,17 @@ require (
 	atomicgo.dev/cursor v0.2.0 // indirect
 	atomicgo.dev/keyboard v0.2.9 // indirect
 	atomicgo.dev/schedule v0.1.0 // indirect
-	cloud.google.com/go v0.112.0 // indirect
+	cloud.google.com/go v0.111.0 // indirect
 	cloud.google.com/go/ai v0.3.0 // indirect
 	cloud.google.com/go/compute v1.23.3 // 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
-	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
+	github.com/Azure/azure-sdk-for-go/sdk/azcore v1.9.1 // indirect
+	github.com/Azure/azure-sdk-for-go/sdk/internal v1.5.1 // indirect
+	github.com/AzureAD/microsoft-authentication-library-for-go v1.2.0 // indirect
 	github.com/Microsoft/hcsshim v0.11.4 // indirect
-	github.com/alecthomas/units v0.0.0-20231202071711-9a357b53e9c9 // indirect
+	github.com/alecthomas/units v0.0.0-20211218093645-b94a6e3cc137 // indirect
 	github.com/anchore/go-struct-converter v0.0.0-20230627203149-c72ef8859ca9 // indirect
 	github.com/cohere-ai/tokenizer v1.1.1 // indirect
 	github.com/containerd/console v1.0.3 // indirect
@@ -66,34 +66,33 @@ require (
 	github.com/evanphx/json-patch/v5 v5.7.0 // indirect
 	github.com/felixge/httpsnoop v1.0.4 // indirect
 	github.com/go-kit/log v0.2.1 // indirect
-	github.com/go-logfmt/logfmt v0.6.0 // indirect
-	github.com/golang-jwt/jwt/v5 v5.2.0 // indirect
+	github.com/go-logfmt/logfmt v0.5.1 // indirect
+	github.com/golang-jwt/jwt/v5 v5.0.0 // indirect
 	github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect
 	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/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/pkg/browser v0.0.0-20210911075715-681adbf594b8 // indirect
 	github.com/prometheus/common/sigv4 v0.1.0 // indirect
 	github.com/sagikazarmark/locafero v0.4.0 // indirect
 	github.com/sagikazarmark/slog-shim v0.1.0 // indirect
 	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/otel/metric v1.23.0 // indirect
-	google.golang.org/genproto v0.0.0-20240125205218-1f4bbc51befe // indirect
+	go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.46.1 // indirect
+	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.46.1 // indirect
+	go.opentelemetry.io/otel/metric v1.21.0 // indirect
+	google.golang.org/genproto v0.0.0-20240116215550-a9fa1716bcac // 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/googleapis/rpc v0.0.0-20240125205218-1f4bbc51befe // indirect
 	gopkg.in/evanphx/json-patch.v5 v5.7.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )
@@ -133,7 +132,7 @@ require (
 	github.com/fsnotify/fsnotify v1.7.0 // indirect
 	github.com/go-errors/errors v1.5.1 // indirect
 	github.com/go-gorp/gorp/v3 v3.1.0 // indirect
-	github.com/go-logr/logr v1.4.1 // indirect
+	github.com/go-logr/logr v1.3.0 // indirect
 	github.com/go-logr/stdr v1.2.2 // indirect
 	github.com/go-openapi/jsonpointer v0.20.0 // indirect
 	github.com/go-openapi/jsonreference v0.20.2 // indirect
@@ -147,7 +146,7 @@ require (
 	github.com/google/go-containerregistry v0.16.1 // indirect
 	github.com/google/gofuzz v1.2.0 // indirect
 	github.com/google/shlex v0.0.0-20191202100458-e7afc7fbc510 // indirect
-	github.com/google/uuid v1.6.0 // indirect
+	github.com/google/uuid v1.5.0 // indirect
 	github.com/gorilla/mux v1.8.0 // indirect
 	github.com/gosuri/uitable v0.0.4 // indirect
 	github.com/gregjones/httpcache v0.0.0-20190611155906-901d90724c79 // indirect
@@ -160,7 +159,7 @@ require (
 	github.com/jmoiron/sqlx v1.3.5 // indirect
 	github.com/josharian/intern v1.0.0 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect
-	github.com/klauspost/compress v1.17.4 // indirect
+	github.com/klauspost/compress v1.17.2 // indirect
 	github.com/lann/builder v0.0.0-20180802200727-47ae307949d0 // indirect
 	github.com/lann/ps v0.0.0-20150810152359-62de8c46ede0 // indirect
 	github.com/lib/pq v1.10.9 // indirect
@@ -209,22 +208,22 @@ require (
 	github.com/xeipuuv/gojsonreference v0.0.0-20180127040603-bd5ef7bd5415 // indirect
 	github.com/xeipuuv/gojsonschema v1.2.0 // indirect
 	github.com/xlab/treeprint v1.2.0 // indirect
-	go.opentelemetry.io/otel v1.23.0 // indirect
-	go.opentelemetry.io/otel/trace v1.23.0 // indirect
+	go.opentelemetry.io/otel v1.21.0 // indirect
+	go.opentelemetry.io/otel/trace v1.21.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
-	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/oauth2 v0.17.0 // indirect
-	golang.org/x/sync v0.6.0 // indirect
-	golang.org/x/sys v0.17.0 // indirect
+	golang.org/x/crypto v0.18.0 // indirect
+	golang.org/x/exp v0.0.0-20231110203233-9a3e6036ecaa // indirect
+	golang.org/x/net v0.20.0
+	golang.org/x/oauth2 v0.16.0 // indirect
+	golang.org/x/sync v0.5.0 // indirect
+	golang.org/x/sys v0.16.0 // indirect
 	golang.org/x/text v0.14.0 // indirect
 	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.61.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
@@ -232,9 +231,9 @@ require (
 	k8s.io/apiserver v0.28.4 // indirect
 	k8s.io/cli-runtime v0.28.4 // indirect
 	k8s.io/component-base v0.28.4 // indirect
-	k8s.io/klog/v2 v2.110.1 // indirect
+	k8s.io/klog/v2 v2.100.1 // indirect
 	k8s.io/kube-openapi v0.0.0-20231010175941-2dd684a91f00 // indirect
-	k8s.io/utils v0.0.0-20240102154912-e7106e64919e
+	k8s.io/utils v0.0.0-20230726121419-3b25d923346b // indirect
 	oras.land/oras-go v1.2.4 // indirect
 	sigs.k8s.io/json v0.0.0-20221116044647-bc3834ca7abd // indirect
 	sigs.k8s.io/kustomize/api v0.15.0 // indirect

pkg/ai/huggingface.go

@@ -1,59 +0,0 @@
-package ai
-
-import (
-	"context"
-	"github.com/hupe1980/go-huggingface"
-	"k8s.io/utils/ptr"
-)
-
-const huggingfaceAIClientName = "huggingface"
-
-type HuggingfaceClient struct {
-	nopCloser
-
-	client      *huggingface.InferenceClient
-	model       string
-	topP        float32
-	temperature float32
-	maxTokens   int
-}
-
-func (c *HuggingfaceClient) Configure(config IAIConfig) error {
-	token := config.GetPassword()
-
-	client := huggingface.NewInferenceClient(token)
-
-	c.client = client
-	c.model = config.GetModel()
-	c.topP = config.GetTopP()
-	c.temperature = config.GetTemperature()
-	if config.GetMaxTokens() > 500 {
-		c.maxTokens = 500
-	} else {
-		c.maxTokens = config.GetMaxTokens()
-	}
-	return nil
-}
-
-func (c *HuggingfaceClient) GetCompletion(ctx context.Context, prompt string) (string, error) {
-	resp, err := c.client.Conversational(ctx, &huggingface.ConversationalRequest{
-		Inputs: huggingface.ConverstationalInputs{
-			Text: prompt,
-		},
-		Model: c.model,
-		Parameters: huggingface.ConversationalParameters{
-			TopP:        ptr.To[float64](float64(c.topP)),
-			Temperature: ptr.To[float64](float64(c.temperature)),
-			MaxLength:   &c.maxTokens,
-		},
-		Options: huggingface.Options{
-			WaitForModel: ptr.To[bool](true),
-		},
-	})
-	if err != nil {
-		return "", err
-	}
-	return resp.GeneratedText, nil
-}
-
-func (c *HuggingfaceClient) GetName() string { return huggingfaceAIClientName }

pkg/ai/iai.go

@@ -27,7 +27,6 @@ var (
 		&AmazonBedRockClient{},
 		&SageMakerAIClient{},
 		&GoogleGenAIClient{},
-		&HuggingfaceClient{},
 	}
 	Backends = []string{
 		openAIClientName,
@@ -38,7 +37,6 @@ var (
 		amazonsagemakerAIClientName,
 		googleAIClientName,
 		noopAIClientName,
-		huggingfaceAIClientName,
 	}
 )
 

pkg/analysis/analysis.go

@@ -28,7 +28,6 @@ import (
 	"github.com/k8sgpt-ai/k8sgpt/pkg/analyzer"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/cache"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
-	"github.com/k8sgpt-ai/k8sgpt/pkg/custom"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/util"
 	"github.com/schollz/progressbar/v3"
@@ -51,10 +50,8 @@ type Analysis struct {
 	WithDoc            bool
 }
 
-type (
-	AnalysisStatus string
-	AnalysisErrors []string
-)
+type AnalysisStatus string
+type AnalysisErrors []string
 
 const (
 	StateOK              AnalysisStatus = "OK"
@@ -150,27 +147,6 @@ func NewAnalysis(
 	return a, nil
 }
 
-func (a *Analysis) RunCustomAnalysis() {
-	var customAnalyzers []custom.CustomAnalyzer
-	if err := viper.UnmarshalKey("custom_analyzers", &customAnalyzers); err != nil {
-		a.Errors = append(a.Errors, err.Error())
-	}
-
-	for _, cAnalyzer := range customAnalyzers {
-
-		canClient, err := custom.NewClient(cAnalyzer.Connection)
-		if err != nil {
-			a.Errors = append(a.Errors, fmt.Sprintf("Client creation error for %s analyzer", cAnalyzer.Name))
-			continue
-		}
-
-		result, err := canClient.Run()
-		if err != nil {
-			a.Results = append(a.Results, result)
-		}
-	}
-}
-
 func (a *Analysis) RunAnalysis() {
 	activeFilters := viper.GetStringSlice("active_filters")
 

pkg/analyzer/gateway.go

@@ -37,10 +37,7 @@ func (GatewayAnalyzer) Analyze(a common.Analyzer) ([]common.Result, error) {
 	gtwList := &gtwapi.GatewayList{}
 	gc := &gtwapi.GatewayClass{}
 	client := a.Client.CtrlClient
-	err := gtwapi.AddToScheme(client.Scheme())
-	if err != nil {
-		return nil, err
-	}
+	gtwapi.AddToScheme(client.Scheme())
 	if err := client.List(a.Context, gtwList, &ctrl.ListOptions{}); err != nil {
 		return nil, err
 	}

pkg/analyzer/gateway_test.go

@@ -56,15 +56,8 @@ func TestGatewayAnalyzer(t *testing.T) {
 	Gateway := BuildGateway(ClassName, AcceptedStatus)
 	// Create a Gateway Analyzer instance with the fake client
 	scheme := scheme.Scheme
-
-	err := gtwapi.Install(scheme)
-	if err != nil {
-		t.Error(err)
-	}
-	err = apiextensionsv1.AddToScheme(scheme)
-	if err != nil {
-		t.Error(err)
-	}
+	gtwapi.Install(scheme)
+	apiextensionsv1.AddToScheme(scheme)
 	objects := []runtime.Object{
 		&Gateway,
 		&GatewayClass,
@@ -95,14 +88,8 @@ func TestMissingClassGatewayAnalyzer(t *testing.T) {
 
 	// Create a Gateway Analyzer instance with the fake client
 	scheme := scheme.Scheme
-	err := gtwapi.Install(scheme)
-	if err != nil {
-		t.Error(err)
-	}
-	err = apiextensionsv1.AddToScheme(scheme)
-	if err != nil {
-		t.Error(err)
-	}
+	gtwapi.Install(scheme)
+	apiextensionsv1.AddToScheme(scheme)
 	objects := []runtime.Object{
 		&Gateway,
 	}
@@ -134,14 +121,8 @@ func TestStatusGatewayAnalyzer(t *testing.T) {
 
 	// Create a Gateway Analyzer instance with the fake client
 	scheme := scheme.Scheme
-	err := gtwapi.Install(scheme)
-	if err != nil {
-		t.Error(err)
-	}
-	err = apiextensionsv1.AddToScheme(scheme)
-	if err != nil {
-		t.Error(err)
-	}
+	gtwapi.Install(scheme)
+	apiextensionsv1.AddToScheme(scheme)
 	objects := []runtime.Object{
 		&Gateway,
 		&GatewayClass,

pkg/analyzer/gatewayclass.go

@@ -35,10 +35,7 @@ func (GatewayClassAnalyzer) Analyze(a common.Analyzer) ([]common.Result, error)
 
 	gcList := &gtwapi.GatewayClassList{}
 	client := a.Client.CtrlClient
-	err := gtwapi.AddToScheme(client.Scheme())
-	if err != nil {
-		return nil, err
-	}
+	gtwapi.AddToScheme(client.Scheme())
 	if err := client.List(a.Context, gcList, &ctrl.ListOptions{}); err != nil {
 		return nil, err
 	}

pkg/analyzer/gatewayclass_test.go

@@ -29,14 +29,8 @@ func TestGatewayClassAnalyzer(t *testing.T) {
 	GatewayClass.Status.Conditions = []metav1.Condition{BadCondition}
 	// Create a GatewayClassAnalyzer instance with the fake client
 	scheme := scheme.Scheme
-	err := gtwapi.Install(scheme)
-	if err != nil {
-		t.Error(err)
-	}
-	err = apiextensionsv1.AddToScheme(scheme)
-	if err != nil {
-		t.Error(err)
-	}
+	gtwapi.Install(scheme)
+	apiextensionsv1.AddToScheme(scheme)
 
 	fakeClient := fakeclient.NewClientBuilder().WithScheme(scheme).WithRuntimeObjects(GatewayClass).Build()
 

pkg/analyzer/httroute.go

@@ -38,16 +38,14 @@ func (HTTPRouteAnalyzer) Analyze(a common.Analyzer) ([]common.Result, error) {
 	gtw := &gtwapi.Gateway{}
 	service := &corev1.Service{}
 	client := a.Client.CtrlClient
-	err := gtwapi.AddToScheme(client.Scheme())
-	if err != nil {
-		return nil, err
-	}
+	gtwapi.AddToScheme(client.Scheme())
 	if err := client.List(a.Context, routeList, &ctrl.ListOptions{}); err != nil {
 		return nil, err
 	}
 	var preAnalysis = map[string]common.PreAnalysis{}
 
 	// Find all unhealthy gateway Classes
+
 	for _, route := range routeList.Items {
 		var failures []common.Failure
 

pkg/analyzer/httroute_test.go

@@ -104,14 +104,8 @@ func TestGWMissiningHTTRouteAnalyzer(t *testing.T) {
 	HTTPRoute := BuildHTTPRoute(backendName, gtwName, gtwNamespace, &svcPort, httpRouteNamespace)
 	// Create a Gateway Analyzer instance with the fake client
 	scheme := scheme.Scheme
-	err := gtwapi.Install(scheme)
-	if err != nil {
-		t.Error(err)
-	}
-	err = apiextensionsv1.AddToScheme(scheme)
-	if err != nil {
-		t.Error(err)
-	}
+	gtwapi.Install(scheme)
+	apiextensionsv1.AddToScheme(scheme)
 	objects := []runtime.Object{
 		&HTTPRoute,
 	}
@@ -162,14 +156,8 @@ func TestGWConfigSameHTTRouteAnalyzer(t *testing.T) {
 	Gateway := BuildRouteGateway("differentnamespace", "gatewayname", "Same")
 	// Create a Gateway Analyzer instance with the fake client
 	scheme := scheme.Scheme
-	err := gtwapi.Install(scheme)
-	if err != nil {
-		t.Error(err)
-	}
-	err = apiextensionsv1.AddToScheme(scheme)
-	if err != nil {
-		t.Error(err)
-	}
+	gtwapi.Install(scheme)
+	apiextensionsv1.AddToScheme(scheme)
 	objects := []runtime.Object{
 		&HTTPRoute,
 		&Gateway,
@@ -219,14 +207,8 @@ func TestGWConfigSelectorHTTRouteAnalyzer(t *testing.T) {
 	Gateway := BuildRouteGateway("default", "gatewayname", "Selector")
 	// Create a Gateway Analyzer instance with the fake client
 	scheme := scheme.Scheme
-	err := gtwapi.Install(scheme)
-	if err != nil {
-		t.Error(err)
-	}
-	err = apiextensionsv1.AddToScheme(scheme)
-	if err != nil {
-		t.Error(err)
-	}
+	gtwapi.Install(scheme)
+	apiextensionsv1.AddToScheme(scheme)
 	objects := []runtime.Object{
 		&HTTPRoute,
 		&Gateway,
@@ -277,14 +259,8 @@ func TestSvcMissingHTTRouteAnalyzer(t *testing.T) {
 	Gateway := BuildRouteGateway("default", "gatewayname", "Same")
 	// Create a Gateway Analyzer instance with the fake client
 	scheme := scheme.Scheme
-	err := gtwapi.Install(scheme)
-	if err != nil {
-		t.Error(err)
-	}
-	err = apiextensionsv1.AddToScheme(scheme)
-	if err != nil {
-		t.Error(err)
-	}
+	gtwapi.Install(scheme)
+	apiextensionsv1.AddToScheme(scheme)
 	objects := []runtime.Object{
 		&HTTPRoute,
 		&Gateway,
@@ -356,14 +332,8 @@ func TestSvcDifferentPortHTTRouteAnalyzer(t *testing.T) {
 	Gateway := BuildRouteGateway("default", "gatewayname", "Same")
 	// Create a Gateway Analyzer instance with the fake client
 	scheme := scheme.Scheme
-	err := gtwapi.Install(scheme)
-	if err != nil {
-		t.Error(err)
-	}
-	err = apiextensionsv1.AddToScheme(scheme)
-	if err != nil {
-		t.Error(err)
-	}
+	gtwapi.Install(scheme)
+	apiextensionsv1.AddToScheme(scheme)
 	objects := []runtime.Object{
 		&HTTPRoute,
 		&Gateway,

pkg/analyzer/mutating_webhook.go

@@ -75,11 +75,6 @@ func (MutatingWebhookAnalyzer) Analyze(a common.Analyzer) ([]common.Result, erro
 						},
 					},
 				})
-				preAnalysis[fmt.Sprintf("%s/%s", webhookConfig.Namespace, webhook.Name)] = common.PreAnalysis{
-					MutatingWebhook: webhookConfig,
-					FailureDetails:  failures,
-				}
-				AnalyzerErrorsMetric.WithLabelValues(kind, webhook.Name, webhookConfig.Namespace).Set(float64(len(failures)))
 				continue
 			}
 

pkg/analyzer/pod.go

@@ -77,7 +77,7 @@ func (PodAnalyzer) Analyze(a common.Analyzer) ([]common.Result, error) {
 					if err != nil || evt == nil {
 						continue
 					}
-					if isEvtErrorReason(evt.Reason) && evt.Message != "" {
+					if evt.Reason == "FailedCreatePodSandBox" && evt.Message != "" {
 						failures = append(failures, common.Failure{
 							Text:      evt.Message,
 							Sensitive: []common.Sensitive{},
@@ -137,21 +137,7 @@ func (PodAnalyzer) Analyze(a common.Analyzer) ([]common.Result, error) {
 
 func isErrorReason(reason string) bool {
 	failureReasons := []string{
-		"CrashLoopBackOff", "ImagePullBackOff", "CreateContainerConfigError", "PreCreateHookError", "CreateContainerError",
-		"PreStartHookError", "RunContainerError", "ImageInspectError", "ErrImagePull", "ErrImageNeverPull", "InvalidImageName",
-	}
-
-	for _, r := range failureReasons {
-		if r == reason {
-			return true
-		}
-	}
-	return false
-}
-
-func isEvtErrorReason(reason string) bool {
-	failureReasons := []string{
-		"FailedCreatePodSandBox", "FailedMount",
+		"CrashLoopBackOff", "ImagePullBackOff", "CreateContainerConfigError", "PreCreateHookError", "CreateContainerError", "PreStartHookError", "RunContainerError", "ImageInspectError", "ErrImagePull", "ErrImageNeverPull", "InvalidImageName",
 	}
 
 	for _, r := range failureReasons {

pkg/analyzer/validating_webhook.go

@@ -73,11 +73,6 @@ func (ValidatingWebhookAnalyzer) Analyze(a common.Analyzer) ([]common.Result, er
 						},
 					},
 				})
-				preAnalysis[fmt.Sprintf("%s/%s", webhookConfig.Namespace, webhook.Name)] = common.PreAnalysis{
-					ValidatingWebhook: webhookConfig,
-					FailureDetails:    failures,
-				}
-				AnalyzerErrorsMetric.WithLabelValues(kind, webhook.Name, webhookConfig.Namespace).Set(float64(len(failures)))
 				continue
 			}
 

pkg/custom/client.go

@@ -1,57 +0,0 @@
-package custom
-
-import (
-	rpc "buf.build/gen/go/k8sgpt-ai/k8sgpt/grpc/go/schema/v1/schemav1grpc"
-	schemav1 "buf.build/gen/go/k8sgpt-ai/k8sgpt/protocolbuffers/go/schema/v1"
-	"context"
-	"fmt"
-	"github.com/k8sgpt-ai/k8sgpt/pkg/common"
-	"google.golang.org/grpc"
-	"google.golang.org/grpc/credentials/insecure"
-)
-
-type Client struct {
-	c              *grpc.ClientConn
-	analyzerClient rpc.AnalyzerServiceClient
-}
-
-func NewClient(c Connection) (*Client, error) {
-
-	conn, err := grpc.Dial(fmt.Sprintf("%s:%s", c.Url, c.Port), grpc.WithTransportCredentials(insecure.NewCredentials()))
-
-	if err != nil {
-		return nil, err
-	}
-	client := rpc.NewAnalyzerServiceClient(conn)
-	return &Client{
-		c:              conn,
-		analyzerClient: client,
-	}, nil
-}
-
-func (cli *Client) Run() (common.Result, error) {
-	var result common.Result
-	req := &schemav1.AnalyzerRunRequest{}
-	res, err := cli.analyzerClient.Run(context.Background(), req)
-	if err != nil {
-		return result, err
-	}
-	if res.Result != nil {
-
-		// We should refactor this, because Error and Failure do not map 1:1 from K8sGPT/schema
-		var errorsFound []common.Failure
-		for _, e := range res.Result.Error {
-			errorsFound = append(errorsFound, common.Failure{
-				Text: e.Text,
-				// TODO: Support sensitive data
-			})
-		}
-
-		result.Name = res.Result.Name
-		result.Kind = res.Result.Kind
-		result.Details = res.Result.Details
-		result.ParentObject = res.Result.ParentObject
-		result.Error = errorsFound
-	}
-	return result, nil
-}

pkg/custom/types.go

@@ -1,10 +0,0 @@
-package custom
-
-type Connection struct {
-	Url  string `json:"url"`
-	Port string `json:"port"`
-}
-type CustomAnalyzer struct {
-	Name       string     `json:"name"`
-	Connection Connection `json:"connection"`
-}

pkg/integration/prometheus/config_analyzer.go

@@ -122,7 +122,7 @@ func findPrometheusPodConfigs(ctx context.Context, client kubernetes.Interface,
 	var configCache = make(map[string]bool)
 
 	for _, pod := range pods {
-		// Extract volume of Prometheus config.
+		// Extract volume of Promethues config.
 		volume, key, err := findPrometheusConfigVolumeAndKey(ctx, client, &pod)
 		if err != nil {
 			return nil, err
@@ -192,10 +192,10 @@ func findPrometheusConfigPath(ctx context.Context, client kubernetes.Interface,
 			// references the ConfigMap or Secret volume mount.
 			// Fallback to the prometheus container if that's not found.
 			if strings.HasPrefix(arg, prometheusConfigFlag) {
-				path = strings.TrimPrefix(arg, prometheusConfigFlag)
+				path = strings.TrimLeft(arg, prometheusConfigFlag)
 			}
 			if strings.HasPrefix(arg, configReloaderConfigFlag) {
-				path = strings.TrimPrefix(arg, configReloaderConfigFlag)
+				path = strings.TrimLeft(arg, configReloaderConfigFlag)
 			}
 		}
 		if container.Name == configReloaderContainerName {

pkg/integration/trivy/analyzer.go

@@ -33,10 +33,7 @@ func (TrivyAnalyzer) analyzeVulnerabilityReports(a common.Analyzer) ([]common.Re
 	result := &v1alpha1.VulnerabilityReportList{}
 
 	client := a.Client.CtrlClient
-	err := v1alpha1.AddToScheme(client.Scheme())
-	if err != nil {
-		return nil, err
-	}
+	v1alpha1.AddToScheme(client.Scheme())
 	if err := client.List(a.Context, result, &ctrl.ListOptions{}); err != nil {
 		return nil, err
 	}
@@ -88,10 +85,7 @@ func (t TrivyAnalyzer) analyzeConfigAuditReports(a common.Analyzer) ([]common.Re
 	result := &v1alpha1.ConfigAuditReportList{}
 
 	client := a.Client.CtrlClient
-	err := v1alpha1.AddToScheme(client.Scheme())
-	if err != nil {
-		return nil, err
-	}
+	v1alpha1.AddToScheme(client.Scheme())
 	if err := client.List(a.Context, result, &ctrl.ListOptions{}); err != nil {
 		return nil, err
 	}

pkg/server/integration.go

@@ -38,9 +38,6 @@ func (h *handler) syncIntegration(ctx context.Context,
 		activeFilters = coreFilters
 	}
 	var err error = status.Error(codes.OK, "")
-	if err != nil {
-		fmt.Println(err)
-	}
 	deactivateFunc := func(integrationRef integration.IIntegration) error {
 		namespace, err := integrationRef.GetNamespace()
 		if err != nil {
@@ -128,19 +125,13 @@ func (*handler) deactivateAllIntegrations(integrationProvider *integration.Integ
 		b, _ := integrationProvider.IsActivate(i)
 		if b {
 			in, err := integrationProvider.Get(i)
-			if err != nil {
-				return err
-			}
 			namespace, err := in.GetNamespace()
 			if err != nil {
 				return err
 			}
 			if err == nil {
 				if namespace != "" {
-					err := integrationProvider.Deactivate(i, namespace)
-					if err != nil {
-						return err
-					}
+					integrationProvider.Deactivate(i, namespace)
 				} else {
 					fmt.Printf("Skipping deactivation of %s, not installed\n", i)
 				}

pkg/server/server.go

@@ -14,31 +14,42 @@ limitations under the License.
 package server
 
 import (
+	"context"
+	json "encoding/json"
 	"errors"
 	"fmt"
+	"log"
 	"net"
 	"net/http"
+	"strconv"
+	"strings"
 	"time"
 
 	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"
 )
 
 type Config struct {
-	Port          string
-	MetricsPort   string
-	Backend       string
-	Key           string
-	Token         string
-	Output        string
-	Handler       *handler
-	Logger        *zap.Logger
-	metricsServer *http.Server
-	listener      net.Listener
+	Port           string
+	MetricsPort    string
+	Backend        string
+	Key            string
+	Token          string
+	Output         string
+	maxConcurrency int
+	Handler        *handler
+	Logger         *zap.Logger
+	metricsServer  *http.Server
+	listener       net.Listener
+	EnableHttp     bool
 }
 
 type Health struct {
@@ -47,7 +58,6 @@ type Health struct {
 	Failure int    `json:"failure"`
 }
 
-//nolint:unused
 var health = Health{
 	Status:  "ok",
 	Success: 0,
@@ -58,8 +68,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 +88,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 = rpc.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
@@ -103,3 +144,21 @@ func (s *Config) ServeMetrics() error {
 	}
 	return nil
 }
+
+func (s *Config) healthzHandler(w http.ResponseWriter, r *http.Request) {
+	js, err := json.MarshalIndent(health, "", "  ")
+	if err != nil {
+		http.Error(w, err.Error(), http.StatusInternalServerError)
+		return
+	}
+	fmt.Fprint(w, string(js))
+}
+
+func getBoolParam(param string) bool {
+	b, err := strconv.ParseBool(strings.ToLower(param))
+	if err != nil {
+		// Handle error if conversion fails
+		return false
+	}
+	return b
+}

pkg/server/server_test.go

@@ -2,6 +2,7 @@ package server
 
 import (
 	"os"
+	"sync"
 	"testing"
 
 	"github.com/fatih/color"
@@ -15,7 +16,6 @@ func TestServerInit(t *testing.T) {
 		color.Red("failed to create logger: %v", err)
 		os.Exit(1)
 	}
-	//nolint:all
 	defer logger.Sync()
 	server_config := Config{
 		Backend:     "openai",
@@ -24,15 +24,19 @@ func TestServerInit(t *testing.T) {
 		Token:       "none",
 		Logger:      logger,
 	}
+	var wg sync.WaitGroup
 
 	go func() {
+		wg.Add(1)
 		err := server_config.Serve()
 		if err != nil {
 			assert.Fail(t, "serve: %s", err.Error())
 		}
-		err = server_config.Shutdown()
+		server_config.Shutdown()
 		if err != nil {
 			assert.Fail(t, "shutdown: %s", err.Error())
 		}
+		wg.Done()
 	}()
+	wg.Wait()
 }