feat(config): kube context name parameter

pkg/config/config.go

@@ -11,11 +11,12 @@ import (
 type StaticConfig struct {
 	DeniedResources []GroupVersionKind `toml:"denied_resources"`
 
-	LogLevel   int    `toml:"log_level,omitempty"`
-	Port       string `toml:"port,omitempty"`
-	SSEBaseURL string `toml:"sse_base_url,omitempty"`
-	KubeConfig string `toml:"kubeconfig,omitempty"`
-	ListOutput string `toml:"list_output,omitempty"`
+	LogLevel    int    `toml:"log_level,omitempty"`
+	Port        string `toml:"port,omitempty"`
+	SSEBaseURL  string `toml:"sse_base_url,omitempty"`
+	KubeConfig  string `toml:"kubeconfig,omitempty"`
+	KubeContext string `toml:"kubecontext,omitempty"`
+	ListOutput  string `toml:"list_output,omitempty"`
 	// When true, expose only tools annotated with readOnlyHint=true
 	ReadOnly bool `toml:"read_only,omitempty"`
 	// When true, disable tools annotated with destructiveHint=true

pkg/kubernetes-mcp-server/cmd/root.go

@@ -57,6 +57,7 @@ type MCPServerOptions struct {
 	HttpPort             int
 	SSEBaseUrl           string
 	Kubeconfig           string
+	KubeContext          string
 	Profile              string
 	ListOutput           string
 	ReadOnly             bool
@@ -114,6 +115,7 @@ func NewMCPServer(streams genericiooptions.IOStreams) *cobra.Command {
 	cmd.Flags().StringVar(&o.Port, "port", o.Port, "Start a streamable HTTP and SSE HTTP server on the specified port (e.g. 8080)")
 	cmd.Flags().StringVar(&o.SSEBaseUrl, "sse-base-url", o.SSEBaseUrl, "SSE public base URL to use when sending the endpoint message (e.g. https://example.com)")
 	cmd.Flags().StringVar(&o.Kubeconfig, "kubeconfig", o.Kubeconfig, "Path to the kubeconfig file to use for authentication")
+	cmd.Flags().StringVar(&o.KubeContext, "kubecontext", o.Kubeconfig, "Context name from kube config")
 	cmd.Flags().StringVar(&o.Profile, "profile", o.Profile, "MCP profile to use (one of: "+strings.Join(mcp.ProfileNames, ", ")+")")
 	cmd.Flags().StringVar(&o.ListOutput, "list-output", o.ListOutput, "Output format for resource list operations (one of: "+strings.Join(output.Names, ", ")+"). Defaults to table.")
 	cmd.Flags().BoolVar(&o.ReadOnly, "read-only", o.ReadOnly, "If true, only tools annotated with readOnlyHint=true are exposed")
@@ -170,6 +172,9 @@ func (m *MCPServerOptions) loadFlags(cmd *cobra.Command) {
 	if cmd.Flag("kubeconfig").Changed {
 		m.StaticConfig.KubeConfig = m.Kubeconfig
 	}
+	if cmd.Flag("kubecontext").Changed {
+		m.StaticConfig.KubeContext = m.KubeContext
+	}
 	if cmd.Flag("list-output").Changed || m.StaticConfig.ListOutput == "" {
 		m.StaticConfig.ListOutput = m.ListOutput
 	}

pkg/kubernetes/configuration.go

@@ -27,9 +27,13 @@ func resolveKubernetesConfigurations(kubernetes *Manager) error {
 	if kubernetes.staticConfig.KubeConfig != "" {
 		pathOptions.LoadingRules.ExplicitPath = kubernetes.staticConfig.KubeConfig
 	}
+	overrides := &clientcmd.ConfigOverrides{ClusterInfo: clientcmdapi.Cluster{Server: ""}}
+	if kubernetes.staticConfig.KubeContext != "" {
+		overrides.CurrentContext = kubernetes.staticConfig.KubeContext
+	}
 	kubernetes.clientCmdConfig = clientcmd.NewNonInteractiveDeferredLoadingClientConfig(
 		pathOptions.LoadingRules,
-		&clientcmd.ConfigOverrides{ClusterInfo: clientcmdapi.Cluster{Server: ""}})
+		overrides)
 	var err error
 	if kubernetes.IsInCluster() {
 		kubernetes.cfg, err = InClusterConfig()
@@ -102,6 +106,9 @@ func (m *Manager) ConfigurationView(minify bool) (runtime.Object, error) {
 		return nil, err
 	}
 	if minify {
+		if m.staticConfig.KubeContext != "" {
+			cfg.CurrentContext = m.staticConfig.KubeContext
+		}
 		if err = clientcmdapi.MinifyConfig(&cfg); err != nil {
 			return nil, err
 		}