Merge pull request #50 from gatewayd-io/add-scan-and-keys-metrics

Add scan and keys metrics

Author: mostafa

plugin/metrics.go

@@ -32,4 +32,14 @@ var (
 		Name:      "cache_deletes_total",
 		Help:      "The total number of cache deletes",
 	})
+	CacheScanCounter = promauto.NewCounter(prometheus.CounterOpts{
+		Namespace: metrics.Namespace,
+		Name:      "cache_scans_total",
+		Help:      "The total number of cache scans",
+	})
+	CacheScanKeysCounter = promauto.NewCounter(prometheus.CounterOpts{
+		Namespace: metrics.Namespace,
+		Name:      "cache_scan_keys_total",
+		Help:      "The total number of cache scan keys",
+	})
 )

plugin/plugin.go

@@ -276,10 +276,12 @@ func (p *Plugin) invalidateDML(ctx context.Context, query string) {
 				p.Logger.Debug("Failed to scan keys", "error", scanResult.Err())
 				break
 			}
+			CacheScanCounter.Inc()
 
 			// Per each key, delete the cache entry and the table cache key itself.
 			var keys []string
 			keys, cursor = scanResult.Val()
+			CacheScanKeysCounter.Add(float64(len(keys)))
 			for _, tableKey := range keys {
 				// Invalidate the cache for the table.
 				cachedRespnseKey := strings.TrimPrefix(tableKey, table+":")

plugin/scheduler.go

@@ -28,9 +28,11 @@ func (p *Plugin) PeriodicInvalidator() {
 				p.Logger.Error("Failed to scan keys", "error", scanResult.Err())
 				break
 			}
+			CacheScanCounter.Inc()
 
 			var addresses []string
 			addresses, cursor = scanResult.Val()
+			CacheScanKeysCounter.Add(float64(len(addresses)))
 			for _, address := range addresses {
 				valid := false