From 0a3c007122c8bdd4496295e9fb87eed6d2f36ba2 Mon Sep 17 00:00:00 2001 From: Alberto Soto Date: Fri, 7 Feb 2025 12:24:06 +0100 Subject: [PATCH] rename --- pkg/experiment/compactor/compaction_worker.go | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/pkg/experiment/compactor/compaction_worker.go b/pkg/experiment/compactor/compaction_worker.go index fc4c272f27..e46117e701 100644 --- a/pkg/experiment/compactor/compaction_worker.go +++ b/pkg/experiment/compactor/compaction_worker.go @@ -50,11 +50,11 @@ type Worker struct { } type Config struct { - JobConcurrency int `yaml:"job_capacity"` - JobPollInterval time.Duration `yaml:"job_poll_interval"` - SmallObjectSize int `yaml:"small_object_size_bytes"` - TempDir string `yaml:"temp_dir"` - RequestTimeout time.Duration `yaml:"request_timeout"` + JobConcurrency int `yaml:"job_capacity"` + JobPollInterval time.Duration `yaml:"job_poll_interval"` + SmallObjectSize int `yaml:"small_object_size_bytes"` + TempDir string `yaml:"temp_dir"` + RequestTimeout time.Duration `yaml:"request_timeout"` MetricsExporterEnabled bool `yaml:"metrics_exporter_enabled"` } @@ -65,7 +65,7 @@ func (cfg *Config) RegisterFlags(f *flag.FlagSet) { f.DurationVar(&cfg.RequestTimeout, prefix+"request-timeout", 5*time.Second, "Job request timeout.") f.IntVar(&cfg.SmallObjectSize, prefix+"small-object-size-bytes", 8<<20, "Size of the object that can be loaded in memory.") f.StringVar(&cfg.TempDir, prefix+"temp-dir", os.TempDir(), "Temporary directory for compaction jobs.") - f.BoolVar(&cfg.EnableMetricsExporter, prefix+"metrics-exporter.enabled", false, "This parameter specifies whether the metrics exporter is enabled.") + f.BoolVar(&cfg.MetricsExporterEnabled, prefix+"metrics-exporter.enabled", false, "This parameter specifies whether the metrics exporter is enabled.") } type compactionJob struct { @@ -403,7 +403,7 @@ func (w *Worker) runCompaction(job *compactionJob) { block.WithObjectMaxSizeLoadInMemory(w.config.SmallObjectSize), block.WithObjectDownload(sourcedir), ), - block.WithSampleObserver(newSampleObserver(w.config.EnableMetricsExporter, job)), + block.WithSampleObserver(newSampleObserver(w.config.MetricsExporterEnabled, job)), ) defer func() { if err = os.RemoveAll(tempdir); err != nil {