Add 'DeqeuedAt' for better monitoring at hooked backends

itzloop · May 29, 2024 · 63594de · 63594de
1 parent b42df17
commit 63594de
Show file tree

Hide file tree

Showing 24 changed files with 65 additions and 52 deletions.
diff --git a/infra/link.pb.go b/infra/link.pb.go
diff --git a/infra/link_grpc.pb.go b/infra/link_grpc.pb.go
diff --git a/livekit/livekit_agent.pb.go b/livekit/livekit_agent.pb.go
diff --git a/livekit/livekit_analytics.pb.go b/livekit/livekit_analytics.pb.go
diff --git a/livekit/livekit_analytics_grpc.pb.go b/livekit/livekit_analytics_grpc.pb.go
diff --git a/livekit/livekit_egress.pb.go b/livekit/livekit_egress.pb.go
diff --git a/livekit/livekit_ingress.pb.go b/livekit/livekit_ingress.pb.go
diff --git a/livekit/livekit_internal.pb.go b/livekit/livekit_internal.pb.go
diff --git a/livekit/livekit_models.pb.go b/livekit/livekit_models.pb.go
diff --git a/livekit/livekit_room.pb.go b/livekit/livekit_room.pb.go
diff --git a/livekit/livekit_rtc.pb.go b/livekit/livekit_rtc.pb.go
diff --git a/livekit/livekit_sip.pb.go b/livekit/livekit_sip.pb.go
diff --git a/livekit/livekit_webhook.pb.go b/livekit/livekit_webhook.pb.go
diff --git a/protobufs/livekit_webhook.proto b/protobufs/livekit_webhook.proto
@@ -49,7 +49,9 @@ message WebhookEvent {
   // timestamp in seconds
   int64 created_at = 7;
 
+  int64 dequeued_at = 13;
+
   int32 num_dropped = 11;
 
-  // NEXT_ID: 12
+  // NEXT_ID: 13
 }
diff --git a/rpc/agent.pb.go b/rpc/agent.pb.go
diff --git a/rpc/egress.pb.go b/rpc/egress.pb.go
diff --git a/rpc/ingress.pb.go b/rpc/ingress.pb.go
diff --git a/rpc/io.pb.go b/rpc/io.pb.go
diff --git a/rpc/keepalive.pb.go b/rpc/keepalive.pb.go
diff --git a/rpc/participant.pb.go b/rpc/participant.pb.go
diff --git a/rpc/room.pb.go b/rpc/room.pb.go
diff --git a/rpc/signal.pb.go b/rpc/signal.pb.go
diff --git a/rpc/sip.pb.go b/rpc/sip.pb.go
diff --git a/webhook/url_notifier.go b/webhook/url_notifier.go
@@ -103,6 +103,7 @@ func (n *URLNotifier) Stop(force bool) {
 func (n *URLNotifier) send(event *livekit.WebhookEvent) error {
 	// set dropped count
 	event.NumDropped = n.dropped.Swap(0)
+	event.DequeuedAt = time.Now().Unix()
 	encoded, err := protojson.Marshal(event)
 	if err != nil {
 		return err