mcp

Documentation

Index

• type MCPClient
  • func NewMCPClient(serverURL string, headers map[string]string) (*MCPClient, error)
  • func (c *MCPClient) CallTool(ctx context.Context, toolName string, params any) (*mcp_golang.ToolResponse, error)
  • func (c *MCPClient) Close() error
  • func (c *MCPClient) ListTools(ctx context.Context) (*mcp_golang.ToolsResponse, error)
• type WebSocketClientTransport
  • func NewWebSocketClientTransport(serverURL string) *WebSocketClientTransport
  • func (t *WebSocketClientTransport) Close(ctx context.Context) error
  • func (t *WebSocketClientTransport) Send(ctx context.Context, message *transport.BaseJsonRpcMessage) error
  • func (t *WebSocketClientTransport) SetCloseHandler(handler func(ctx context.Context))
  • func (t *WebSocketClientTransport) SetErrorHandler(handler func(error))
  • func (t *WebSocketClientTransport) SetMessageHandler(handler func(ctx context.Context, message *transport.BaseJsonRpcMessage))
  • func (t *WebSocketClientTransport) Start(ctx context.Context) error
  • func (t *WebSocketClientTransport) WithHeader(key, value string) *WebSocketClientTransport

Types

type MCPClient

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

func NewMCPClient

func NewMCPClient(serverURL string, headers map[string]string) (*MCPClient, error)

func (*MCPClient) CallTool

func (c *MCPClient) CallTool(ctx context.Context, toolName string, params any) (*mcp_golang.ToolResponse, error)

func (*MCPClient) Close

func (c *MCPClient) Close() error

func (*MCPClient) ListTools

func (c *MCPClient) ListTools(ctx context.Context) (*mcp_golang.ToolsResponse, error)

type WebSocketClientTransport

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

WebSocketClientTransport provides a client transport implementation for MCP over WebSockets

func NewWebSocketClientTransport

func NewWebSocketClientTransport(serverURL string) *WebSocketClientTransport

NewWebSocketClientTransport creates a new WebSocket client transport

func (*WebSocketClientTransport) Close

func (t *WebSocketClientTransport) Close(ctx context.Context) error

Close closes the WebSocket connection

func (*WebSocketClientTransport) Send

func (t *WebSocketClientTransport) Send(ctx context.Context, message *transport.BaseJsonRpcMessage) error

Send sends a message to the WebSocket server

func (*WebSocketClientTransport) SetCloseHandler

func (t *WebSocketClientTransport) SetCloseHandler(handler func(ctx context.Context))

SetCloseHandler sets the callback for when the connection is closed

func (*WebSocketClientTransport) SetErrorHandler

func (t *WebSocketClientTransport) SetErrorHandler(handler func(error))

SetErrorHandler sets the callback for when an error occurs

func (*WebSocketClientTransport) SetMessageHandler

func (t *WebSocketClientTransport) SetMessageHandler(handler func(ctx context.Context, message *transport.BaseJsonRpcMessage))

SetMessageHandler sets the callback for when a message is received

func (*WebSocketClientTransport) Start

func (t *WebSocketClientTransport) Start(ctx context.Context) error

Start connects to the WebSocket server and starts handling messages

func (*WebSocketClientTransport) WithHeader

func (t *WebSocketClientTransport) WithHeader(key, value string) *WebSocketClientTransport

WithHeader adds a header to the WebSocket handshake request