fix concurrent mishaviour

collectors/collectors.go

@@ -13,7 +13,8 @@ type ObjectCollector interface {
 }
 
 type Collector struct {
-	fetcher    *fetcher.Fetcher
+	workers    int
+	config     *fetcher.CFConfig
 	filter     *filters.Filter
 	collectors []ObjectCollector
 }
@@ -22,11 +23,13 @@ func NewCollector(
 	namespace string,
 	environment string,
 	deployment string,
-	fetcher *fetcher.Fetcher,
+	workers int,
+	config *fetcher.CFConfig,
 	filter *filters.Filter,
 ) (*Collector, error) {
 	res := &Collector{
-		fetcher:    fetcher,
+		workers:    workers,
+		config:     config,
 		filter:     filter,
 		collectors: []ObjectCollector{},
 	}
@@ -100,7 +103,8 @@ func NewCollector(
 }
 
 func (c *Collector) Collect(ch chan<- prometheus.Metric) {
-	objs := c.fetcher.GetObjects()
+	fetcher := fetcher.NewFetcher(c.workers, c.config, c.filter)
+	objs := fetcher.GetObjects()
 	for _, collector := range c.collectors {
 		collector.Collect(objs, ch)
 	}

main.go

@@ -171,9 +171,7 @@ func main() {
 		os.Exit(1)
 	}
 
-	up := fetcher.NewFetcher(*workers, config, filter)
-
-	c, err := collectors.NewCollector(*metricsNamespace, *metricsEnvironment, *cfDeploymentName, up, filter)
+	c, err := collectors.NewCollector(*metricsNamespace, *metricsEnvironment, *cfDeploymentName, *workers, config, filter)
 	if err != nil {
 		log.Error(err)
 		os.Exit(1)