Method createTransport

agent/x/agentmcp/manager.go:963–990

createTransport builds the mcp-go transport for a server config.

(ctx context.Context, cfg ServerConfig)

// createTransport builds the mcp-go transport for a server config.
func (m *Manager) createTransport(ctx context.Context, cfg ServerConfig) (transport.Interface, error) {
	switch cfg.Transport {
	case "stdio":
		env := m.buildEnv(ctx, cfg.Env)
		return transport.NewStdioWithOptions(
			cfg.Command,
			env,
			cfg.Args,
			transport.WithCommandFunc(func(ctx context.Context, command string, cmdEnv []string, args []string) (*exec.Cmd, error) {
				cmd := m.execer.CommandContext(ctx, command, args...)
				cmd.Env = cmdEnv
				return cmd, nil
			}),
		), nil
	case "http", "":
		return transport.NewStreamableHTTP(
			cfg.URL,
			transport.WithHTTPHeaders(cfg.Headers),
		)
	case "sse":
		return transport.NewSSE(
			cfg.URL,
			transport.WithHeaders(cfg.Headers),
		)
	default:
		return nil, xerrors.Errorf("unsupported transport %q", cfg.Transport)
	}
}

// buildEnv enriches the process environment via the agent's
// updateEnv callback, then merges explicit overrides from the