Removed the source queue and pulled object from the channel

engedaam · engedaam · commit 226bf39d4d0e · 2025-01-24T12:56:40.000-08:00
diff --git a/events/controller.go b/events/controller.go
@@ -38,6 +38,7 @@ func NewController[T client.Object](ctx context.Context, client client.Client, c
 		kubeClient: client,
 		EventCount: eventTotalMetric(strings.ToLower(gvk.Kind)),
 		EventWatch: lo.Must(kubernetesInterface.CoreV1().Events("").Watch(ctx, metav1.ListOptions{
+			// Only reconcile on the object kind we care about
 			FieldSelector: fmt.Sprintf("involvedObject.kind=%s,involvedObject.apiVersion=%s", gvk.Kind, gvk.GroupVersion().String()),
 		})),
 	}

Original file line number	Diff line number	Diff line change
`@@ -38,6 +38,7 @@ func NewController[T client.Object](ctx context.Context, client client.Client, c`
`38`	`38`	`kubeClient: client,`
`39`	`39`	`EventCount: eventTotalMetric(strings.ToLower(gvk.Kind)),`
`40`	`40`	`EventWatch: lo.Must(kubernetesInterface.CoreV1().Events("").Watch(ctx, metav1.ListOptions{`
	`41`	`+ // Only reconcile on the object kind we care about`
`41`	`42`	`FieldSelector: fmt.Sprintf("involvedObject.kind=%s,involvedObject.apiVersion=%s", gvk.Kind, gvk.GroupVersion().String()),`
`42`	`43`	`})),`
`43`	`44`	`}`