test

package

v0.0.54 Latest Latest Go to latest Published: Nov 12, 2025 License: Apache-2.0 Imports: 27 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/containers/kubernetes-mcp-server

Links

Open Source Insights

Documentation ¶

Index ¶

func KubeConfigFake() *clientcmdapi.Config
func KubeconfigFile(t *testing.T, kubeconfig *api.Config) string
func McpInitRequest() mcp.InitializeRequest
func Must[T any](v T, err error) T
func RandomPortAddress() (*net.TCPAddr, error)
func ReadFile(path ...string) string
func RestoreEnv(originalEnv []string)
func WaitForServer(tcpAddr *net.TCPAddr) error
func WriteObject(w http.ResponseWriter, obj runtime.Object)
type InOpenShiftHandler
- func (h *InOpenShiftHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)
type McpClient
- func NewMcpClient(t *testing.T, mcpHttpServer http.Handler, ...) *McpClient
- func (m *McpClient) CallTool(name string, args map[string]interface{}) (*mcp.CallToolResult, error)
- func (m *McpClient) Close()
type MockServer
- func NewMockServer() *MockServer
- func (m *MockServer) Close()
- func (m *MockServer) Config() *rest.Config
- func (m *MockServer) Handle(handler http.Handler)
- func (m *MockServer) Kubeconfig() *api.Config
- func (m *MockServer) KubeconfigFile(t *testing.T) string
- func (m *MockServer) ResetHandlers()
type StreamContext
- func CreateHTTPStreams(w http.ResponseWriter, req *http.Request, opts *StreamOptions) (*StreamContext, error)
type StreamOptions
type TokenReviewHandler
- func (h *TokenReviewHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func KubeConfigFake ¶ added in v0.0.51

func KubeConfigFake() *clientcmdapi.Config

func KubeconfigFile ¶ added in v0.0.53

func KubeconfigFile(t *testing.T, kubeconfig *api.Config) string

func McpInitRequest ¶ added in v0.0.54

func McpInitRequest() mcp.InitializeRequest

func Must ¶ added in v0.0.51

func Must[T any](v T, err error) T

func RandomPortAddress ¶ added in v0.0.54

func RandomPortAddress() (*net.TCPAddr, error)

func ReadFile ¶ added in v0.0.52

func ReadFile(path ...string) string

func RestoreEnv ¶ added in v0.0.54

func RestoreEnv(originalEnv []string)

func WaitForServer ¶ added in v0.0.54

func WaitForServer(tcpAddr *net.TCPAddr) error

func WriteObject ¶

func WriteObject(w http.ResponseWriter, obj runtime.Object)

Types ¶

type InOpenShiftHandler ¶ added in v0.0.51

type InOpenShiftHandler struct {
}

func (*InOpenShiftHandler) ServeHTTP ¶ added in v0.0.51

func (h *InOpenShiftHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)

type McpClient ¶ added in v0.0.51

type McpClient struct {
	*client.Client
	// contains filtered or unexported fields
}

func NewMcpClient ¶ added in v0.0.51

func NewMcpClient(t *testing.T, mcpHttpServer http.Handler, options ...transport.StreamableHTTPCOption) *McpClient

func (*McpClient) CallTool ¶ added in v0.0.51

func (m *McpClient) CallTool(name string, args map[string]interface{}) (*mcp.CallToolResult, error)

CallTool helper function to call a tool by name with arguments

func (*McpClient) Close ¶ added in v0.0.51

func (m *McpClient) Close()

type MockServer ¶

type MockServer struct {
	// contains filtered or unexported fields
}

func NewMockServer ¶

func NewMockServer() *MockServer

func (*MockServer) Close ¶

func (m *MockServer) Close()

func (*MockServer) Config ¶

func (m *MockServer) Config() *rest.Config

func (*MockServer) Handle ¶

func (m *MockServer) Handle(handler http.Handler)

func (*MockServer) Kubeconfig ¶ added in v0.0.51

func (m *MockServer) Kubeconfig() *api.Config

func (*MockServer) KubeconfigFile ¶ added in v0.0.51

func (m *MockServer) KubeconfigFile(t *testing.T) string

func (*MockServer) ResetHandlers ¶ added in v0.0.54

func (m *MockServer) ResetHandlers()

type StreamContext ¶

type StreamContext struct {
	Closer       io.Closer
	StdinStream  io.ReadCloser
	StdoutStream io.WriteCloser
	StderrStream io.WriteCloser
	// contains filtered or unexported fields
}

func CreateHTTPStreams ¶

func CreateHTTPStreams(w http.ResponseWriter, req *http.Request, opts *StreamOptions) (*StreamContext, error)

type StreamOptions ¶

type StreamOptions struct {
	Stdin  io.Reader
	Stdout io.Writer
	Stderr io.Writer
}

type TokenReviewHandler ¶ added in v0.0.54

type TokenReviewHandler struct {
	TokenReviewed bool
}

func (*TokenReviewHandler) ServeHTTP ¶ added in v0.0.54

func (h *TokenReviewHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL