From 2ec1de96d551c64deb817d8c71a81a0a286ca34e Mon Sep 17 00:00:00 2001 From: yusing Date: Mon, 14 Apr 2025 06:31:04 +0800 Subject: [PATCH] chore: cont. d8eff90 --- internal/metrics/period/poller.go | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/internal/metrics/period/poller.go b/internal/metrics/period/poller.go index 9422f7a8..f60014de 100644 --- a/internal/metrics/period/poller.go +++ b/internal/metrics/period/poller.go @@ -10,6 +10,7 @@ import ( "sync" "time" + "github.com/yusing/go-proxy/internal/common" "github.com/yusing/go-proxy/internal/gperr" "github.com/yusing/go-proxy/internal/logging" "github.com/yusing/go-proxy/internal/task" @@ -39,14 +40,12 @@ const ( pollInterval = 1 * time.Second gatherErrsInterval = 30 * time.Second saveInterval = 5 * time.Minute - - saveBaseDir = "data/metrics" ) var initDataDirOnce sync.Once func initDataDir() { - if err := os.MkdirAll(saveBaseDir, 0o755); err != nil { + if err := os.MkdirAll(common.MetricsDataDir, 0o755); err != nil { logging.Error().Err(err).Msg("failed to create metrics data directory") } } @@ -65,7 +64,7 @@ func NewPoller[T any, AggregateT json.Marshaler]( } func (p *Poller[T, AggregateT]) savePath() string { - return filepath.Join(saveBaseDir, fmt.Sprintf("%s.json", p.name)) + return filepath.Join(common.MetricsDataDir, fmt.Sprintf("%s.json", p.name)) } func (p *Poller[T, AggregateT]) load() error {