Add 'DeqeuedAt' for better monitoring at hooked backends

itzloop · May 29, 2024 · a0b48d8 · a0b48d8
1 parent a17da31
commit a0b48d8
Show file tree

Hide file tree

Showing 24 changed files with 69 additions and 56 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/webhook_test.go b/webhook/webhook_test.go
@@ -145,10 +145,11 @@ func TestURLNotifierLifecycle(t *testing.T) {
 
 func newTestNotifier() *URLNotifier {
 	return NewURLNotifier(URLNotifierParams{
-		QueueSize: 20,
-		URL:       testUrl,
-		APIKey:    apiKey,
-		APISecret: apiSecret,
+		QueueSize:    20,
+		URL:          testUrl,
+		APIKey:       apiKey,
+		APISecret:    apiSecret,
+		DropWhenFull: true,
 	})
 }