refreshCacheMetrics refreshes cacheSize and cacheItems metrics.
()
| 805 | |
| 806 | // refreshCacheMetrics refreshes cacheSize and cacheItems metrics. |
| 807 | func (rp *reverseProxy) refreshCacheMetrics() { |
| 808 | rp.lock.RLock() |
| 809 | defer rp.lock.RUnlock() |
| 810 | |
| 811 | for _, c := range rp.caches { |
| 812 | stats := c.Stats() |
| 813 | labels := prometheus.Labels{ |
| 814 | "cache": c.Name(), |
| 815 | } |
| 816 | cacheSize.With(labels).Set(float64(stats.Size)) |
| 817 | cacheItems.With(labels).Set(float64(stats.Items)) |
| 818 | } |
| 819 | } |
| 820 | |
| 821 | // find user, cluster and clusterUser |
| 822 | // in case of wildcarded user, cluster user is crafted to use original credentials |