command

package
v0.3.2 Latest Latest
Warning

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

 Go to latest Published: Mar 8, 2026 License: MIT Imports: 23 Imported by: 1

Documentation

Overview

Package command implements a registry for Model Context Protocol (MCP) servers. It provides integration with MCP tools, allowing agents to dynamically discover and invoke tools exposed by MCP servers.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewAuthTransport added in v0.3.2 

func NewAuthTransport(spec AuthConfig) (*mcp.StreamableClientTransport, error)

Configures MCP transport with Bearer token authentication.

Types

type AuthConfig added in v0.3.2 

type AuthConfig struct {
	// Endpoint URL of MCP server
	Endpoint string

	// Resource Config file (default is ~/.iqrc) to read credentials from.
	RC string

	// Custom HTTP client (if nil, default client will be used)
	Client *http.Client
}

type Registry 

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

func NewRegistry 

func NewRegistry() *Registry

NewRegistry creates a new registry of MCP servers.

func (*Registry) Attach added in v0.3.0 

func (r *Registry) Attach(id string, server Server) error

Attach MCP server to the registry, making its tools available to the agent. The server is identified by a unique prefix, which is used to namespace tool names (e.g., fs_read). Tool names use underscore separator (prefix_toolname) due to AWS Bedrock constraints which only allow [a-zA-Z0-9_-] characters. The first token before underscore is always the server prefix. Each server runs independently, and its tools are registered with the prefix to avoid naming conflicts.

func (*Registry) ConnectCmd added in v0.3.2 

func (r *Registry) ConnectCmd(id string, cmd []string) error

func (*Registry) ConnectUrl added in v0.3.2 

func (r *Registry) ConnectUrl(id string, url string) error

func (*Registry) Context added in v0.0.20 

func (r *Registry) Context() chatter.Registry

Context returns the registry as LLM embeddable schema. It fetches the list of available tools from all attached MCP servers.

func (*Registry) Invoke added in v0.0.20 

func (r *Registry) Invoke(reply *chatter.Reply) (thinker.Phase, chatter.Message, error)

Invoke executes the tools requested by the LLM via the appropriate MCP server.

type Server added in v0.3.0 

type Server interface {
	ListTools(ctx context.Context, params *mcp.ListToolsParams) (*mcp.ListToolsResult, error)
	CallTool(ctx context.Context, params *mcp.CallToolParams) (*mcp.CallToolResult, error)
	Close() error
}

MCP Server interface

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.