fix stale collector

mkabilov · mkabilov · commit 4310988f35fb · 2018-09-17T16:19:54.000+02:00
diff --git a/pkg/pgcollector/pgcollector.go b/pkg/pgcollector/pgcollector.go
@@ -239,9 +239,11 @@ func (p *PgCollector) Collect(metricsCh chan<- prometheus.Metric) {
 		}
 
 		for _, query := range dbConf.Queries() {
-			dbJobs[dbName] <- &workerJob{
-				dbLabels: dbConf.Labels(),
-				Query:    query,
+			if len(dbPool[dbName]) > 0 {
+				dbJobs[dbName] <- &workerJob{
+					dbLabels: dbConf.Labels(),
+					Query:    query,
+				}
 			}
 		}
 		close(dbJobs[dbName])

Original file line number	Diff line number	Diff line change
`@@ -239,9 +239,11 @@ func (p *PgCollector) Collect(metricsCh chan<- prometheus.Metric) {`
`239`	`239`	`}`
`240`	`240`
`241`	`241`	`for _, query := range dbConf.Queries() {`
`242`		`- dbJobs[dbName] <- &workerJob{`
`243`		`- dbLabels: dbConf.Labels(),`
`244`		`- Query: query,`
	`242`	`+ if len(dbPool[dbName]) > 0 {`
	`243`	`+ dbJobs[dbName] <- &workerJob{`
	`244`	`+ dbLabels: dbConf.Labels(),`
	`245`	`+ Query: query,`
	`246`	`+ }`
`245`	`247`	`}`
`246`	`248`	`}`
`247`	`249`	`close(dbJobs[dbName])`