Merge branch 'feat/add-bedrockmantle-provider' of https://github.com/sankeyraut/k8sgpt into feat/add-bedrockmantle-provider

Author: sankeyraut

.release-please-manifest.json

@@ -1 +1 @@
-{".":"0.4.31"}
+{".":"0.4.32"}

CHANGELOG.md

@@ -1,5 +1,21 @@
 # Changelog
 
+## [0.4.32](https://github.com/k8sgpt-ai/k8sgpt/compare/v0.4.31...v0.4.32) (2026-04-21)
+
+
+### Features
+
+* add Azure API Type Support and add Custom HTTP Header ([#1638](https://github.com/k8sgpt-ai/k8sgpt/issues/1638)) ([28fe196](https://github.com/k8sgpt-ai/k8sgpt/commit/28fe196d47ca43cf984f6b07a78cc3f877dc3cc2))
+* add daemonset analyzer and special cases for pod and job ([#1636](https://github.com/k8sgpt-ai/k8sgpt/issues/1636)) ([ac329d1](https://github.com/k8sgpt-ai/k8sgpt/commit/ac329d18909d61e67d16fe07e6fda22b84a7e689))
+
+
+### Bug Fixes
+
+* amazonbedrockconverse claude models temp and topp ([#1629](https://github.com/k8sgpt-ai/k8sgpt/issues/1629)) ([c87a31a](https://github.com/k8sgpt-ai/k8sgpt/commit/c87a31aee13a60b343dae4abef6e1ee6eed148c9))
+* **deps:** update module google.golang.org/grpc to v1.79.3 [security] ([#1626](https://github.com/k8sgpt-ai/k8sgpt/issues/1626)) ([97fbf04](https://github.com/k8sgpt-ai/k8sgpt/commit/97fbf04e331b4a6f37c494b8becd8c6f0687af8b))
+* improve ConfigMap usage detection for sidecar patterns ([#1602](https://github.com/k8sgpt-ai/k8sgpt/issues/1602)) ([ca0d3eb](https://github.com/k8sgpt-ai/k8sgpt/commit/ca0d3eba3faaf1b786e62b1a5cabad02ae799d6d))
+* recognize GKE built-in ingress classes 'gce' and 'gce-internal' ([#1599](https://github.com/k8sgpt-ai/k8sgpt/issues/1599)) ([6ba8fb2](https://github.com/k8sgpt-ai/k8sgpt/commit/6ba8fb217d874e41d5737161a1f8fb1fd1acf4d4))
+
 ## [0.4.31](https://github.com/k8sgpt-ai/k8sgpt/compare/v0.4.30...v0.4.31) (2026-03-24)
 
 

README.md

@@ -67,15 +67,15 @@ brew install k8sgpt
   <!---x-release-please-start-version-->
 
   ```
-  sudo rpm -ivh https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.4.31/k8sgpt_386.rpm
+  sudo rpm -ivh https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.4.32/k8sgpt_386.rpm
   ```
   <!---x-release-please-end-->
 
 **64 bit:**
 
   <!---x-release-please-start-version-->
   ```
-  sudo rpm -ivh https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.4.31/k8sgpt_amd64.rpm
+  sudo rpm -ivh https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.4.32/k8sgpt_amd64.rpm
   ```
   <!---x-release-please-end-->
 </details>
@@ -88,7 +88,7 @@ brew install k8sgpt
   <!---x-release-please-start-version-->
 
 ```
-curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.4.31/k8sgpt_386.deb
+curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.4.32/k8sgpt_386.deb
 sudo dpkg -i k8sgpt_386.deb
 ```
 
@@ -99,7 +99,7 @@ sudo dpkg -i k8sgpt_386.deb
   <!---x-release-please-start-version-->
 
 ```
-curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.4.31/k8sgpt_amd64.deb
+curl -LO https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.4.32/k8sgpt_amd64.deb
 sudo dpkg -i k8sgpt_amd64.deb
 ```
 
@@ -114,7 +114,7 @@ sudo dpkg -i k8sgpt_amd64.deb
 
   <!---x-release-please-start-version-->
   ```
-  wget https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.4.31/k8sgpt_386.apk
+  wget https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.4.32/k8sgpt_386.apk
   apk add --allow-untrusted k8sgpt_386.apk
   ```
   <!---x-release-please-end-->
@@ -123,7 +123,7 @@ sudo dpkg -i k8sgpt_amd64.deb
 
   <!---x-release-please-start-version-->
   ```
-  wget https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.4.31/k8sgpt_amd64.apk
+  wget https://github.com/k8sgpt-ai/k8sgpt/releases/download/v0.4.32/k8sgpt_amd64.apk
   apk add --allow-untrusted k8sgpt_amd64.apk
   ```
   <!---x-release-please-end-->

cmd/auth/add.go

@@ -21,6 +21,7 @@ import (
 
 	"github.com/fatih/color"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/ai"
+	"github.com/sashabaranov/go-openai"
 	"github.com/spf13/cobra"
 	"github.com/spf13/viper"
 	"golang.org/x/term"
@@ -69,11 +70,21 @@ var addCmd = &cobra.Command{
 			return false
 		}
 
-		// check if backend is not empty and a valid value
-		if backend == "" {
+		switch backend {
+		case "": // check if backend is not empty and a valid value
 			color.Yellow(fmt.Sprintf("Warning: backend input is empty, will use the default value: %s", defaultBackend))
 			backend = defaultBackend
-		} else {
+		case "azureopenai":
+			azureAPIType, _ := cmd.Flags().GetString("azureAPIType")
+
+			switch openai.APIType(azureAPIType) {
+			case "", openai.APITypeAzure, openai.APITypeAzureAD, openai.APITypeCloudflareAzure:
+				// valid types
+			default:
+				color.Red("Error: Valid values of azureAPIType for azureopenai backends are AZURE, AZURE_AD or CLOUDFLARE_AZURE")
+				os.Exit(1)
+			}
+		default:
 			if !validBackend(ai.Backends, backend) {
 				color.Red("Error: Backend AI accepted values are '%v'", strings.Join(ai.Backends, ", "))
 				os.Exit(1)
@@ -148,6 +159,7 @@ var addCmd = &cobra.Command{
 			MaxTokens:      maxTokens,
 			StopSequences:  stopSequences,
 			OrganizationId: organizationId,
+			AzureAPIType:   azureAPIType,
 		}
 
 		if providerIndex == -1 {
@@ -194,4 +206,6 @@ func init() {
 	addCmd.Flags().StringVarP(&compartmentId, "compartmentId", "k", "", "Compartment ID for generative AI model (only for oci backend)")
 	// add flag for openai organization
 	addCmd.Flags().StringVarP(&organizationId, "organizationId", "o", "", "OpenAI or AzureOpenAI Organization ID (only for openai and azureopenai backend)")
+	// add flag for azure open ai APIType name
+	addCmd.Flags().StringVarP(&azureAPIType, "azureAPIType", "a", "", fmt.Sprintf("AzureOpenAI API Type name. Valid values: %s, %s or %s (only for azureopenai backend)", openai.APITypeAzure, openai.APITypeAzureAD, openai.APITypeCloudflareAzure))
 }

cmd/auth/auth.go

@@ -34,6 +34,7 @@ var (
 	maxTokens      int
 	stopSequences  []string
 	organizationId string
+	azureAPIType   string
 )
 
 var configAI ai.AIConfiguration

cmd/auth/update.go

@@ -14,10 +14,12 @@ limitations under the License.
 package auth
 
 import (
+	"fmt"
 	"os"
 	"strings"
 
 	"github.com/fatih/color"
+	"github.com/sashabaranov/go-openai"
 	"github.com/spf13/cobra"
 	"github.com/spf13/viper"
 )
@@ -33,6 +35,16 @@ var updateCmd = &cobra.Command{
 		if strings.ToLower(backend) == "azureopenai" {
 			_ = cmd.MarkFlagRequired("engine")
 			_ = cmd.MarkFlagRequired("baseurl")
+
+			azureAPIType, _ := cmd.Flags().GetString("azureAPIType")
+
+			switch openai.APIType(azureAPIType) {
+			case "", openai.APITypeAzure, openai.APITypeAzureAD, openai.APITypeCloudflareAzure:
+				// valid types
+			default:
+				color.Red("Error: Valid values of azureAPIType for azureopenai backends are AZURE, AZURE_AD or CLOUDFLARE_AZURE")
+				os.Exit(1)
+			}
 		}
 		organizationId, _ := cmd.Flags().GetString("organizationId")
 		if strings.ToLower(backend) != "azureopenai" && strings.ToLower(backend) != "openai" {
@@ -85,6 +97,10 @@ var updateCmd = &cobra.Command{
 					configAI.Providers[i].OrganizationId = organizationId
 					color.Blue("Organization Id updated successfully")
 				}
+				if azureAPIType != "" {
+					configAI.Providers[i].AzureAPIType = azureAPIType
+					color.Blue("AzureAPIType updated successfully")
+				}
 				configAI.Providers[i].Temperature = temperature
 				color.Green("%s updated in the AI backend provider list", backend)
 			}
@@ -117,4 +133,6 @@ func init() {
 	updateCmd.Flags().StringVarP(&engine, "engine", "e", "", "Update Azure AI deployment name")
 	// update flag for organizationId
 	updateCmd.Flags().StringVarP(&organizationId, "organizationId", "o", "", "Update OpenAI or Azure organization Id")
+	// add flag for azure open ai APIType name
+	updateCmd.Flags().StringVarP(&azureAPIType, "azureAPIType", "a", "", fmt.Sprintf("AzureOpenAI API Type name. Valid values: %s, %s or %s (only for azureopenai backend)", openai.APITypeAzure, openai.APITypeAzureAD, openai.APITypeCloudflareAzure))
 }

cmd/serve/serve.go

@@ -14,8 +14,10 @@ limitations under the License.
 package serve
 
 import (
+	"net/http"
 	"os"
 	"strconv"
+	"strings"
 
 	k8sgptserver "github.com/k8sgpt-ai/k8sgpt/pkg/server"
 
@@ -120,12 +122,31 @@ var ServeCmd = &cobra.Command{
 				}
 				return int(maxTokens)
 			}
+
+			// Parse custom headers from environment variable
+			parseCustomHeaders := func() []http.Header {
+				headersEnv := os.Getenv("K8SGPT_CUSTOM_HEADERS")
+				if headersEnv == "" {
+					return nil
+				}
+
+				header := make(http.Header)
+				headerPairs := strings.Split(headersEnv, ",")
+				for _, pair := range headerPairs {
+					kv := strings.SplitN(pair, ":", 2)
+					if len(kv) == 2 {
+						header.Add(strings.TrimSpace(kv[0]), strings.TrimSpace(kv[1]))
+					}
+				}
+				return []http.Header{header}
+			}
 			// Check for env injection
 			backend = os.Getenv("K8SGPT_BACKEND")
 			password := os.Getenv("K8SGPT_PASSWORD")
 			model := os.Getenv("K8SGPT_MODEL")
 			baseURL := os.Getenv("K8SGPT_BASEURL")
 			engine := os.Getenv("K8SGPT_ENGINE")
+			azureAPIType := os.Getenv("K8SGPT_AZURE_API_TYPE")
 			proxyEndpoint := os.Getenv("K8SGPT_PROXY_ENDPOINT")
 			providerId := os.Getenv("K8SGPT_PROVIDER_ID")
 			// If the envs are set, allocate in place to the aiProvider
@@ -138,6 +159,8 @@ var ServeCmd = &cobra.Command{
 					Model:         model,
 					BaseURL:       baseURL,
 					Engine:        engine,
+					AzureAPIType:  azureAPIType,
+					CustomHeaders: parseCustomHeaders(),
 					ProxyEndpoint: proxyEndpoint,
 					ProviderId:    providerId,
 					Temperature:   temperature(),

pkg/ai/amazonbedrockconverse.go

@@ -61,6 +61,11 @@ func processError(err error, modelId string) error {
 	}
 }
 
+func isClaudeModel(modelId string) bool {
+	m := strings.ToLower(modelId)
+	return strings.Contains(m, "claude")
+}
+
 func (a *AmazonBedrockConverseClient) Configure(config IAIConfig) error {
 	modelInput := config.GetModel()
 
@@ -133,15 +138,22 @@ func (a *AmazonBedrockConverseClient) GetCompletion(ctx context.Context, prompt
 		Content: []types.ContentBlock{&content},
 		Role:    "user",
 	}
+
+	var infConfig = &types.InferenceConfiguration{
+		MaxTokens:     aws.Int32(int32(a.maxTokens)),
+		StopSequences: a.stopSequences,
+	}
+
+	// Claude models only support temperature OR topP, while others support both temperature and topP. Prefer temperature for now
+	if !isClaudeModel(a.model) {
+		infConfig.TopP = aws.Float32(a.topP)
+	}
+	infConfig.Temperature = aws.Float32(a.temperature)
+		
 	var converseInput = bedrockruntime.ConverseInput{
 		ModelId:  aws.String(a.model),
 		Messages: []types.Message{message},
-		InferenceConfig: &types.InferenceConfiguration{
-			Temperature:   aws.Float32(a.temperature),
-			TopP:          aws.Float32(a.topP),
-			MaxTokens:     aws.Int32(int32(a.maxTokens)),
-			StopSequences: a.stopSequences,
-		},
+		InferenceConfig: infConfig,
 	}
 	response, err := a.client.Converse(ctx, &converseInput)
 	if err != nil {

pkg/ai/amazonbedrockconverse_mock_test.go

@@ -12,9 +12,11 @@ import (
 // ---- Mock Wrapper ----
 type mockConverseClient struct {
 	converseFunc func(ctx context.Context, input *bedrockruntime.ConverseInput) (*bedrockruntime.ConverseOutput, error)
+	lastInput    *bedrockruntime.ConverseInput
 }
 
 func (m *mockConverseClient) Converse(ctx context.Context, input *bedrockruntime.ConverseInput, _ ...func(*bedrockruntime.Options)) (*bedrockruntime.ConverseOutput, error) {
+	m.lastInput = input
 	return m.converseFunc(ctx, input)
 }
 
@@ -244,6 +246,91 @@ func TestExtractTextFromConverseOutput(t *testing.T) {
 	}
 }
 
+func TestGetCompletion_ClaudeModel_UsesTemperatureOnly(t *testing.T) {
+	mock := &mockConverseClient{
+		converseFunc: func(ctx context.Context, input *bedrockruntime.ConverseInput) (*bedrockruntime.ConverseOutput, error) {
+			return &bedrockruntime.ConverseOutput{
+				Output: &types.ConverseOutputMemberMessage{
+					Value: types.Message{
+						Content: []types.ContentBlock{
+							&types.ContentBlockMemberText{Value: "ok"},
+						},
+					},
+				},
+			}, nil
+		},
+	}
+
+	client := &AmazonBedrockConverseClient{
+		client:      mock,
+		model:       "anthropic.claude-v2",
+		temperature: 0.5,
+		topP:        0.9,
+		maxTokens:   100,
+	}
+
+	_, err := client.GetCompletion(context.Background(), "hello")
+
+	assert.NoError(t, err)
+
+	inf := mock.lastInput.InferenceConfig
+
+	assert.NotNil(t, inf.Temperature)
+	assert.Nil(t, inf.TopP)
+}
+
+func TestGetCompletion_NonClaudeModel_UsesTemperatureAndTopP(t *testing.T) {
+	mock := &mockConverseClient{
+		converseFunc: func(ctx context.Context, input *bedrockruntime.ConverseInput) (*bedrockruntime.ConverseOutput, error) {
+			return &bedrockruntime.ConverseOutput{
+				Output: &types.ConverseOutputMemberMessage{
+					Value: types.Message{
+						Content: []types.ContentBlock{
+							&types.ContentBlockMemberText{Value: "ok"},
+						},
+					},
+				},
+			}, nil
+		},
+	}
+
+	client := &AmazonBedrockConverseClient{
+		client:      mock,
+		model:       "amazon.titan-text",
+		temperature: 0.5,
+		topP:        0.9,
+		maxTokens:   100,
+	}
+
+	_, err := client.GetCompletion(context.Background(), "hello")
+
+	assert.NoError(t, err)
+
+	inf := mock.lastInput.InferenceConfig
+
+	assert.NotNil(t, inf.Temperature)
+	assert.NotNil(t, inf.TopP)
+	assert.Equal(t, float32(0.9), *inf.TopP)
+}
+
+func TestIsClaudeModel(t *testing.T) {
+	tests := []struct {
+		model    string
+		expected bool
+	}{
+		{"anthropic.claude-opus-4-6-v1", true},
+		{"CLAUDE-3", true},
+		{"amazon.titan", false},
+		{"gpt-4", false},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.model, func(t *testing.T) {
+			assert.Equal(t, tt.expected, isClaudeModel(tt.model))
+		})
+	}
+}
+
 func TestGetName(t *testing.T) {
 	client := &AmazonBedrockConverseClient{}
 	assert.Equal(t, "amazonbedrockconverse", client.GetName())