feat(proto): add Pass field to PushPullEvent message for tracking rat…

…elimit decision

chore(proto): update proto file with new fields and messages

feat(proto): add pass field to PushPullEvent message for ratelimit tracking
feat(metrics): add ratelimitAccuracy metric to track ratelimit accuracy
feat(pushpull): update ratelimitAccuracy metric based on ratelimit pass result

apps/agent/proto/ratelimit/v1/service.proto

@@ -44,6 +44,10 @@ message PushPullEvent {
 
   // used for metrics
     int64 time = 5;
+
+// Whether the serving node has decided to pass the ratelimit or not
+// We use this to track the accuracy after syncing with the origin node
+    bool pass = 6;
  }
 
 message PushPullRequest {

apps/agent/services/ratelimit/metrics.go

@@ -0,0 +1,12 @@
+package ratelimit
+
+import (
+	"github.com/prometheus/client_golang/prometheus"
+	"github.com/prometheus/client_golang/prometheus/promauto"
+)
+
+var ratelimitAccuracy = promauto.NewCounterVec(prometheus.CounterOpts{
+	Namespace: "agent",
+	Subsystem: "ratelimit",
+	Name:      "ratelimit_accuracy",
+}, []string{"correct"})

apps/agent/services/ratelimit/pushpull.go

@@ -20,10 +20,17 @@ func (s *service) PushPull(ctx context.Context, req *ratelimitv1.PushPullRequest
 			RefillInterval: e.Duration,
 			Cost:           e.Cost,
 		})
+
 		res.Updates[i] = &ratelimitv1.PushPullUpdate{
 			Identifier: e.Identifier,
 			Current:    r.Current,
 		}
+
+		if r.Pass == e.Pass {
+			ratelimitAccuracy.WithLabelValues("true").Inc()
+		} else {
+			ratelimitAccuracy.WithLabelValues("false").Inc()
+		}
 	}
 
 	return res, nil