boundary/internal/cmd/base/profiling_on.go

// +build memprofiler

package base

import (
	"os"
	"path/filepath"
	"runtime"
	"runtime/pprof"
	"time"

	"github.com/hashicorp/go-hclog"
)

func StartMemProfiler(logger hclog.Logger) {
	profileDir := filepath.Join(os.TempDir(), "watchtowerprof")
	if err := os.MkdirAll(profileDir, 0700); err != nil {
		logger.Debug("could not create profile directory", "error", err)
		return
	}

	go func() {
		for {
			filename := filepath.Join(profileDir, time.Now().UTC().Format("20060102_150405")) + ".pprof"
			f, err := os.Create(filename)
			if err != nil {
				logger.Debug("could not create memory profile", "error", err)
			}
			runtime.GC()
			if err := pprof.WriteHeapProfile(f); err != nil {
				logger.Debug("could not write memory profile", "error", err)
			}
			f.Close()
			logger.Debug("wrote memory profile", "filename", filename)
			time.Sleep(5 * time.Minute)
		}
	}()
}