AddServer 添加 MCP Server
(config *MCPServerConfig)
| 27 | |
| 28 | // AddServer 添加 MCP Server |
| 29 | func (m *MCPManager) AddServer(config *MCPServerConfig) (*MCPServer, error) { |
| 30 | m.mu.Lock() |
| 31 | defer m.mu.Unlock() |
| 32 | |
| 33 | // 检查是否已存在 |
| 34 | if _, exists := m.servers[config.ServerID]; exists { |
| 35 | return nil, fmt.Errorf("server already exists: %s", config.ServerID) |
| 36 | } |
| 37 | |
| 38 | // 创建 Server |
| 39 | server, err := NewMCPServer(config, m.registry) |
| 40 | if err != nil { |
| 41 | return nil, fmt.Errorf("create mcp server: %w", err) |
| 42 | } |
| 43 | |
| 44 | m.servers[config.ServerID] = server |
| 45 | return server, nil |
| 46 | } |
| 47 | |
| 48 | // ConnectServer 连接指定的 MCP Server 并注册工具 |
| 49 | func (m *MCPManager) ConnectServer(ctx context.Context, serverID string) error { |