diff options
| author | Paul Buetow <paul@buetow.org> | 2025-06-26 22:19:22 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2025-06-26 22:19:22 +0300 |
| commit | 947e08e4f9e3c9c44b346adff4eb6d68fa79a726 (patch) | |
| tree | cfa94aba72f91d26657de09b7a5b6a23eff10fd7 /internal/tools/common/utils.go | |
| parent | 1e643ac66765fc0ab4224335191731d8b77fece2 (diff) | |
Refactor profiling and benchmarking tools from bash to Go
This major refactoring replaces all bash-based profiling and benchmarking
scripts with a unified Go tool (dtail-tools) that provides:
- Better cross-platform compatibility
- Improved error handling and reliability
- Structured data generation for test files
- Consistent command-line interface
- Easier maintenance and extensibility
Key changes:
- Created dtail-tools command with profile and benchmark subcommands
- Implemented common utilities for data generation and file operations
- Updated Makefile to use the new Go-based tools
- Maintained backward compatibility with existing make targets
- Fixed ParseSize to handle single-letter suffixes (10M, 1G, etc.)
The new tool supports all previous functionality:
- profile-quick, profile-all, profile-dmap
- benchmark creation, comparison, and management
- Test data generation with multiple formats
- Profile analysis and listing
🤖 Generated with [Claude Code](https://claude.ai/code)
Co-Authored-By: Claude <noreply@anthropic.com>
Diffstat (limited to 'internal/tools/common/utils.go')
| -rw-r--r-- | internal/tools/common/utils.go | 213 |
1 files changed, 213 insertions, 0 deletions
diff --git a/internal/tools/common/utils.go b/internal/tools/common/utils.go new file mode 100644 index 0000000..37f115a --- /dev/null +++ b/internal/tools/common/utils.go @@ -0,0 +1,213 @@ +package common + +import ( + "fmt" + "os" + "os/exec" + "path/filepath" + "strconv" + "strings" + "time" +) + +// ParseSize parses a size string like "10MB", "1GB" into bytes +func ParseSize(sizeStr string) (int64, error) { + originalStr := sizeStr + sizeStr = strings.ToUpper(strings.TrimSpace(sizeStr)) + + // Handle single-letter suffixes (K, M, G, T) by adding B + if len(sizeStr) > 1 { + lastChar := sizeStr[len(sizeStr)-1] + secondLastChar := byte('0') + if len(sizeStr) > 1 { + secondLastChar = sizeStr[len(sizeStr)-2] + } + + // If ends with K, M, G, or T and the character before it is a digit, add B + if (lastChar == 'K' || lastChar == 'M' || lastChar == 'G' || lastChar == 'T') && + (secondLastChar >= '0' && secondLastChar <= '9') { + sizeStr = sizeStr + "B" + } + } + + // Order matters - check longer suffixes first + suffixes := []struct { + suffix string + multiplier int64 + }{ + {"TB", 1024 * 1024 * 1024 * 1024}, + {"GB", 1024 * 1024 * 1024}, + {"MB", 1024 * 1024}, + {"KB", 1024}, + {"B", 1}, + } + + for _, s := range suffixes { + if strings.HasSuffix(sizeStr, s.suffix) { + numStr := strings.TrimSuffix(sizeStr, s.suffix) + numStr = strings.TrimSpace(numStr) + if numStr == "" { + return 0, fmt.Errorf("no number before size suffix") + } + num, err := strconv.ParseFloat(numStr, 64) + if err != nil { + return 0, fmt.Errorf("invalid size number: %s (original: %s, processed: %s)", numStr, originalStr, sizeStr) + } + return int64(num * float64(s.multiplier)), nil + } + } + + // Try parsing as plain number (assume bytes) + num, err := strconv.ParseInt(sizeStr, 10, 64) + if err != nil { + return 0, fmt.Errorf("invalid size format: %s", sizeStr) + } + return num, nil +} + +// FormatSize formats bytes into human-readable size +func FormatSize(bytes int64) string { + const unit = 1024 + if bytes < unit { + return fmt.Sprintf("%d B", bytes) + } + div, exp := int64(unit), 0 + for n := bytes / unit; n >= unit; n /= unit { + div *= unit + exp++ + } + return fmt.Sprintf("%.1f %cB", float64(bytes)/float64(div), "KMGTPE"[exp]) +} + +// BuildCommand builds a dtail command if it doesn't exist +func BuildCommand(cmd string) error { + // Check if binary exists + if _, err := os.Stat(cmd); err == nil { + return nil // Already exists + } + + // Build the command + cmdName := filepath.Base(cmd) + buildCmd := exec.Command("go", "build", "-o", cmd, fmt.Sprintf("./cmd/%s/main.go", cmdName)) + buildCmd.Stdout = os.Stdout + buildCmd.Stderr = os.Stderr + + fmt.Printf("Building %s...\n", cmdName) + return buildCmd.Run() +} + +// BuildCommands builds multiple dtail commands +func BuildCommands(commands ...string) error { + for _, cmd := range commands { + if err := BuildCommand(cmd); err != nil { + return fmt.Errorf("failed to build %s: %w", cmd, err) + } + } + return nil +} + +// EnsureDirectory creates a directory if it doesn't exist +func EnsureDirectory(dir string) error { + return os.MkdirAll(dir, 0755) +} + +// FileExists checks if a file exists +func FileExists(path string) bool { + _, err := os.Stat(path) + return err == nil +} + +// GetTimestamp returns a timestamp string for file naming +func GetTimestamp() string { + return time.Now().Format("20060102_150405") +} + +// GetGitCommit returns the current git commit hash (short form) +func GetGitCommit() string { + cmd := exec.Command("git", "rev-parse", "--short", "HEAD") + output, err := cmd.Output() + if err != nil { + return "unknown" + } + return strings.TrimSpace(string(output)) +} + +// RunCommandWithTimeout runs a command with a timeout +func RunCommandWithTimeout(timeout time.Duration, name string, args ...string) error { + cmd := exec.Command(name, args...) + cmd.Stdout = os.Stdout + cmd.Stderr = os.Stderr + + if err := cmd.Start(); err != nil { + return err + } + + done := make(chan error, 1) + go func() { + done <- cmd.Wait() + }() + + select { + case <-time.After(timeout): + if err := cmd.Process.Kill(); err != nil { + return fmt.Errorf("failed to kill process: %w", err) + } + return fmt.Errorf("command timed out after %v", timeout) + case err := <-done: + return err + } +} + +// CleanupFiles removes temporary files matching patterns +func CleanupFiles(patterns ...string) error { + for _, pattern := range patterns { + matches, err := filepath.Glob(pattern) + if err != nil { + return fmt.Errorf("invalid pattern %s: %w", pattern, err) + } + for _, match := range matches { + if err := os.Remove(match); err != nil && !os.IsNotExist(err) { + return fmt.Errorf("failed to remove %s: %w", match, err) + } + } + } + return nil +} + +// Colors for terminal output +const ( + ColorReset = "\033[0m" + ColorRed = "\033[0;31m" + ColorGreen = "\033[0;32m" + ColorYellow = "\033[1;33m" + ColorBlue = "\033[0;34m" + ColorPurple = "\033[0;35m" + ColorCyan = "\033[0;36m" + ColorWhite = "\033[0;37m" +) + +// PrintColored prints colored text to stdout +func PrintColored(color, format string, args ...interface{}) { + fmt.Printf(color+format+ColorReset, args...) +} + +// PrintSection prints a section header +func PrintSection(title string) { + PrintColored(ColorGreen, "%s\n", title) + fmt.Println(strings.Repeat("=", len(title))) +} + +// PrintInfo prints an info message +func PrintInfo(format string, args ...interface{}) { + PrintColored(ColorYellow, format, args...) +} + +// PrintError prints an error message +func PrintError(format string, args ...interface{}) { + PrintColored(ColorRed, format, args...) +} + +// PrintSuccess prints a success message +func PrintSuccess(format string, args ...interface{}) { + PrintColored(ColorGreen, format, args...) +}
\ No newline at end of file |
