[receiver/purefa] Add a new scraper type volumes (#16738)

receiver/purefareceiver/README.md

@@ -35,6 +35,7 @@ receivers:
         host: 13s
         directories: 15s
         pods: 30s
+        volumes: 25s
 ```
 
 The full list of settings exposed for this receiver are documented [here](./config.go)

receiver/purefareceiver/config.go

@@ -45,6 +45,9 @@ type Config struct {
 
 	// Pods represents the list of pods to query
 	Pods []internal.ScraperConfig `mapstructure:"pods"`
+
+	// Volumes represents the list of volumes to query
+	Volumes []internal.ScraperConfig `mapstructure:"volumes"`
 }
 
 type Settings struct {
@@ -56,6 +59,7 @@ type ReloadIntervals struct {
 	Host        time.Duration `mapstructure:"host"`
 	Directories time.Duration `mapstructure:"directories"`
 	Pods        time.Duration `mapstructure:"pods"`
+	Volumes     time.Duration `mapstructure:"volumes"`
 }
 
 func (c *Config) Validate() error {

receiver/purefareceiver/internal/scraper.go

@@ -38,6 +38,7 @@ const (
 	ScraperTypeHost        ScraperType = "host"
 	ScraperTypeDirectories ScraperType = "directories"
 	ScraperTypePods        ScraperType = "pods"
+	ScraperTypeVolumes     ScraperType = "volumes"
 )
 
 type scraper struct {

receiver/purefareceiver/receiver.go

@@ -75,6 +75,13 @@ func (r *purefaReceiver) Start(ctx context.Context, compHost component.Host) err
 		return err
 	}
 
+	volumesScraper := internal.NewScraper(ctx, internal.ScraperTypeVolumes, r.cfg.Endpoint, r.cfg.Volumes, r.cfg.Settings.ReloadIntervals.Volumes)
+	if scCfgs, err := volumesScraper.ToPrometheusReceiverConfig(compHost, fact); err == nil {
+		scrapeCfgs = append(scrapeCfgs, scCfgs...)
+	} else {
+		return err
+	}
+
 	promRecvCfg := fact.CreateDefaultConfig().(*prometheusreceiver.Config)
 	promRecvCfg.PrometheusConfig = &config.Config{ScrapeConfigs: scrapeCfgs}
 

receiver/purefareceiver/testdata/config.yaml

@@ -17,3 +17,4 @@ receivers:
         host: 13s
         directories: 15s
         pods: 30s
+        volumes: 25s