alihan/kubernetes-mcp-server
1
0
Fork 0
mirror of https://github.com/containers/kubernetes-mcp-server.git synced 2025-10-23 01:22:57 +03:00
Code Issues Packages Projects Releases Wiki Activity

refactor(mcp): use k8s.io/utils ptr.Deref instead of a custom func

Browse Source
This commit is contained in:
Arda Güçlü
2025-06-18 06:10:29 +03:00
committed by GitHub
parent 85876a4621
commit 4a3ff2f2ce
9 changed files with 28 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/mcp/configuration.go
View File

@@ -3,9 +3,11 @@ package mcp
import (
"context"
"fmt"
"github.com/manusa/kubernetes-mcp-server/pkg/output"
"github.com/mark3labs/mcp-go/mcp"
"github.com/mark3labs/mcp-go/server"
"github.com/manusa/kubernetes-mcp-server/pkg/output"
)
func (s *Server) initConfiguration() []server.ServerTool {

4
pkg/mcp/events.go
View File

@@ -3,9 +3,11 @@ package mcp
import (
"context"
"fmt"
"github.com/manusa/kubernetes-mcp-server/pkg/output"
"github.com/mark3labs/mcp-go/mcp"
"github.com/mark3labs/mcp-go/server"
"github.com/manusa/kubernetes-mcp-server/pkg/output"
)
func (s *Server) initEvents() []server.ServerTool {

1
pkg/mcp/helm.go
View File

@@ -3,6 +3,7 @@ package mcp
import (
"context"
"fmt"
"github.com/mark3labs/mcp-go/mcp"
"github.com/mark3labs/mcp-go/server"
)

17
pkg/mcp/mcp.go
View File

@@ -2,12 +2,15 @@ package mcp
import (
"context"
"net/http"
"github.com/mark3labs/mcp-go/mcp"
"github.com/mark3labs/mcp-go/server"
"k8s.io/utils/ptr"
"github.com/manusa/kubernetes-mcp-server/pkg/kubernetes"
"github.com/manusa/kubernetes-mcp-server/pkg/output"
"github.com/manusa/kubernetes-mcp-server/pkg/version"
"github.com/mark3labs/mcp-go/mcp"
"github.com/mark3labs/mcp-go/server"
"net/http"
)
type Configuration struct {
@@ -45,10 +48,6 @@ func NewSever(configuration Configuration) (*Server, error) {
return s, nil
}
func isFalse(value *bool) bool {
return value == nil || !*value
}
func (s *Server) reloadKubernetesClient() error {
k, err := kubernetes.NewKubernetes(s.configuration.Kubeconfig)
if err != nil {
@@ -57,10 +56,10 @@ func (s *Server) reloadKubernetesClient() error {
s.k = k
applicableTools := make([]server.ServerTool, 0)
for _, tool := range s.configuration.Profile.GetTools(s) {
if s.configuration.ReadOnly && isFalse(tool.Tool.Annotations.ReadOnlyHint) {
if s.configuration.ReadOnly && !ptr.Deref(tool.Tool.Annotations.ReadOnlyHint, false) {
continue
}
if s.configuration.DisableDestructive && isFalse(tool.Tool.Annotations.ReadOnlyHint) && !isFalse(tool.Tool.Annotations.DestructiveHint) {
if s.configuration.DisableDestructive && !ptr.Deref(tool.Tool.Annotations.ReadOnlyHint, false) && ptr.Deref(tool.Tool.Annotations.DestructiveHint, false) {
continue
}
applicableTools = append(applicableTools, tool)

4
pkg/mcp/namespaces.go
View File

@@ -3,9 +3,11 @@ package mcp
import (
"context"
"fmt"
"github.com/manusa/kubernetes-mcp-server/pkg/kubernetes"
"github.com/mark3labs/mcp-go/mcp"
"github.com/mark3labs/mcp-go/server"
"github.com/manusa/kubernetes-mcp-server/pkg/kubernetes"
)
func (s *Server) initNamespaces() []server.ServerTool {

7
pkg/mcp/pods.go
View File

@@ -5,12 +5,13 @@ import (
"context"
"errors"
"fmt"
"github.com/manusa/kubernetes-mcp-server/pkg/kubernetes"
"github.com/manusa/kubernetes-mcp-server/pkg/output"
"k8s.io/kubectl/pkg/metricsutil"
"github.com/mark3labs/mcp-go/mcp"
"github.com/mark3labs/mcp-go/server"
"k8s.io/kubectl/pkg/metricsutil"
"github.com/manusa/kubernetes-mcp-server/pkg/kubernetes"
"github.com/manusa/kubernetes-mcp-server/pkg/output"
)
func (s *Server) initPods() []server.ServerTool {

3
pkg/mcp/profiles.go
View File

@@ -1,8 +1,9 @@
package mcp
import (
"github.com/mark3labs/mcp-go/server"
"slices"
"github.com/mark3labs/mcp-go/server"
)
type Profile interface {

5
pkg/mcp/resources.go
View File

@@ -4,12 +4,13 @@ import (
"context"
"errors"
"fmt"
"github.com/manusa/kubernetes-mcp-server/pkg/kubernetes"
"github.com/manusa/kubernetes-mcp-server/pkg/output"
"github.com/mark3labs/mcp-go/mcp"
"github.com/mark3labs/mcp-go/server"
"k8s.io/apimachinery/pkg/runtime/schema"
"github.com/manusa/kubernetes-mcp-server/pkg/kubernetes"
"github.com/manusa/kubernetes-mcp-server/pkg/output"
)
func (s *Server) initResources() []server.ServerTool {

1
pkg/output/output.go
View File

@@ -2,6 +2,7 @@ package output
import (
"bytes"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
"k8s.io/apimachinery/pkg/runtime"