agentmcp

package
v2.32.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 11, 2026 License: AGPL-3.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source
const ToolNameSep = "__"

ToolNameSep separates the server name from the original tool name in prefixed tool names. Double underscore avoids collisions with tool names that may contain single underscores.

Variables

View Source
var (
	// ErrInvalidToolName is returned when the tool name format
	// is not "server__tool".
	ErrInvalidToolName = xerrors.New("invalid tool name format")
	// ErrUnknownServer is returned when no MCP server matches
	// the prefix in the tool name.
	ErrUnknownServer = xerrors.New("unknown MCP server")
)

Functions

This section is empty.

Types

type API

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

API exposes MCP tool discovery and call proxying through the agent.

func NewAPI

func NewAPI(logger slog.Logger, manager *Manager) *API

NewAPI creates a new MCP API handler backed by the given manager.

func (*API) Routes

func (api *API) Routes() http.Handler

Routes returns the HTTP handler for MCP-related routes.

type Manager

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

Manager manages connections to MCP servers discovered from a workspace's .mcp.json file. It caches the aggregated tool list and proxies tool calls to the appropriate server.

func NewManager

func NewManager(logger slog.Logger) *Manager

NewManager creates a new MCP client manager.

func (*Manager) CallTool

CallTool proxies a tool call to the appropriate MCP server.

func (*Manager) Close

func (m *Manager) Close() error

Close terminates all MCP server connections and child processes.

func (*Manager) Connect

func (m *Manager) Connect(ctx context.Context, mcpConfigFiles []string) error

Connect reads MCP config files at the given absolute paths and connects to all configured servers. Failed servers are logged and skipped. Missing config files are silently skipped.

func (*Manager) RefreshTools

func (m *Manager) RefreshTools(ctx context.Context) error

RefreshTools re-fetches tool lists from all connected servers in parallel and rebuilds the cache. On partial failure, tools from servers that responded successfully are merged with the existing cached tools for servers that failed, so a single dead server doesn't block updates from healthy ones.

func (*Manager) Tools

func (m *Manager) Tools() []workspacesdk.MCPToolInfo

Tools returns the cached tool list. Thread-safe.

type ServerConfig

type ServerConfig struct {
	Name      string            `json:"name"`
	Transport string            `json:"type"`
	Command   string            `json:"command"`
	Args      []string          `json:"args"`
	Env       map[string]string `json:"env"`
	URL       string            `json:"url"`
	Headers   map[string]string `json:"headers"`
}

ServerConfig describes a single MCP server parsed from a .mcp.json file.

func ParseConfig

func ParseConfig(path string) ([]ServerConfig, error)

ParseConfig reads a .mcp.json file at path and returns the declared MCP servers sorted by name. It returns an empty slice when the mcpServers key is missing or empty.

Jump to

Keyboard shortcuts

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