Merge pull request #250 from practo/bugfix-conc-map-write

Read also need synchronization
practo · Sep 3, 2021 · 532d0ee · 532d0ee
2 parents aeae0df + e71f99a
commit 532d0ee
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/prometheus/prometheus.go b/pkg/prometheus/prometheus.go
@@ -117,7 +117,9 @@ func (p *promClient) queryWithRetry(
 
 func (p *promClient) Query(queryString string) (float64, error) {
 	// return from cache if cache hit
+	p.mutex.Lock()
 	lastRun, ok := p.queryLastRun[queryString]
+	p.mutex.Unlock()
 	if ok {
 		if cacheValid(p.queryCacheValidity, lastRun) {
 			cache, ok := p.queryCache[queryString]