Skip to content

Commit 93b8ce8

Browse files
authored
Merge pull request #66 from nashluffy/add-handler
✨ Add TypedEnqueueRequestsFromMapFuncWithClusterPreservation function
2 parents 690bf28 + 3197807 commit 93b8ce8

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

pkg/handler/enqueue_mapped.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,3 +34,10 @@ func EnqueueRequestsFromMapFunc(fn handler.MapFunc) EventHandlerFunc {
3434
func TypedEnqueueRequestsFromMapFunc[object client.Object, request mcreconcile.ClusterAware[request]](fn handler.TypedMapFunc[object, request]) TypedEventHandlerFunc[object, request] {
3535
return TypedInjectCluster[object, request](handler.TypedEnqueueRequestsFromMapFunc[object, request](fn))
3636
}
37+
38+
// TypedEnqueueRequestsFromMapFuncWithClusterPreservation wraps handler.TypedEnqueueRequestsFromMapFunc
39+
// to work with mcreconcile.Request while preserving the ClusterName field set in the requests.
40+
// This avoids cluster injection and depends on the mapFunc to set the correct ClusterName in the request.
41+
func TypedEnqueueRequestsFromMapFuncWithClusterPreservation[object client.Object, request mcreconcile.ClusterAware[request]](fn handler.TypedMapFunc[object, request]) handler.TypedEventHandler[object, request] {
42+
return handler.TypedEnqueueRequestsFromMapFunc[object, request](fn)
43+
}

0 commit comments

Comments
 (0)