Skip to content

Commit 44878bd

Browse files
authored
Merge pull request #5671 from sbueringer/pr-fix-predicate-log-values
🐛 Fix predicate log key/values
2 parents ad965df + 3b839fd commit 44878bd

File tree

1 file changed

+16
-16
lines changed

1 file changed

+16
-16
lines changed

util/predicates/generic_predicates.go

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -132,16 +132,16 @@ func Any(logger logr.Logger, predicates ...predicate.Funcs) predicate.Funcs {
132132
func ResourceHasFilterLabel(logger logr.Logger, labelValue string) predicate.Funcs {
133133
return predicate.Funcs{
134134
UpdateFunc: func(e event.UpdateEvent) bool {
135-
return processIfLabelMatch(logger.WithValues("predicate", "updateEvent"), e.ObjectNew, labelValue)
135+
return processIfLabelMatch(logger.WithValues("predicate", "ResourceHasFilterLabel", "eventType", "update"), e.ObjectNew, labelValue)
136136
},
137137
CreateFunc: func(e event.CreateEvent) bool {
138-
return processIfLabelMatch(logger.WithValues("predicate", "createEvent"), e.Object, labelValue)
138+
return processIfLabelMatch(logger.WithValues("predicate", "ResourceHasFilterLabel", "eventType", "create"), e.Object, labelValue)
139139
},
140140
DeleteFunc: func(e event.DeleteEvent) bool {
141-
return processIfLabelMatch(logger.WithValues("predicate", "deleteEvent"), e.Object, labelValue)
141+
return processIfLabelMatch(logger.WithValues("predicate", "ResourceHasFilterLabel", "eventType", "delete"), e.Object, labelValue)
142142
},
143143
GenericFunc: func(e event.GenericEvent) bool {
144-
return processIfLabelMatch(logger.WithValues("predicate", "genericEvent"), e.Object, labelValue)
144+
return processIfLabelMatch(logger.WithValues("predicate", "ResourceHasFilterLabel", "eventType", "generic"), e.Object, labelValue)
145145
},
146146
}
147147
}
@@ -162,16 +162,16 @@ func ResourceHasFilterLabel(logger logr.Logger, labelValue string) predicate.Fun
162162
func ResourceNotPaused(logger logr.Logger) predicate.Funcs {
163163
return predicate.Funcs{
164164
UpdateFunc: func(e event.UpdateEvent) bool {
165-
return processIfNotPaused(logger.WithValues("predicate", "updateEvent"), e.ObjectNew)
165+
return processIfNotPaused(logger.WithValues("predicate", "ResourceNotPaused", "eventType", "update"), e.ObjectNew)
166166
},
167167
CreateFunc: func(e event.CreateEvent) bool {
168-
return processIfNotPaused(logger.WithValues("predicate", "createEvent"), e.Object)
168+
return processIfNotPaused(logger.WithValues("predicate", "ResourceNotPaused", "eventType", "create"), e.Object)
169169
},
170170
DeleteFunc: func(e event.DeleteEvent) bool {
171-
return processIfNotPaused(logger.WithValues("predicate", "deleteEvent"), e.Object)
171+
return processIfNotPaused(logger.WithValues("predicate", "ResourceNotPaused", "eventType", "delete"), e.Object)
172172
},
173173
GenericFunc: func(e event.GenericEvent) bool {
174-
return processIfNotPaused(logger.WithValues("predicate", "genericEvent"), e.Object)
174+
return processIfNotPaused(logger.WithValues("predicate", "ResourceNotPaused", "eventType", "generic"), e.Object)
175175
},
176176
}
177177
}
@@ -216,16 +216,16 @@ func processIfLabelMatch(logger logr.Logger, obj client.Object, labelValue strin
216216
func ResourceIsNotExternallyManaged(logger logr.Logger) predicate.Funcs {
217217
return predicate.Funcs{
218218
UpdateFunc: func(e event.UpdateEvent) bool {
219-
return processIfNotExternallyManaged(logger.WithValues("predicate", "updateEvent"), e.ObjectNew)
219+
return processIfNotExternallyManaged(logger.WithValues("predicate", "ResourceIsNotExternallyManaged", "eventType", "update"), e.ObjectNew)
220220
},
221221
CreateFunc: func(e event.CreateEvent) bool {
222-
return processIfNotExternallyManaged(logger.WithValues("predicate", "createEvent"), e.Object)
222+
return processIfNotExternallyManaged(logger.WithValues("predicate", "ResourceIsNotExternallyManaged", "eventType", "create"), e.Object)
223223
},
224224
DeleteFunc: func(e event.DeleteEvent) bool {
225-
return processIfNotExternallyManaged(logger.WithValues("predicate", "deleteEvent"), e.Object)
225+
return processIfNotExternallyManaged(logger.WithValues("predicate", "ResourceIsNotExternallyManaged", "eventType", "delete"), e.Object)
226226
},
227227
GenericFunc: func(e event.GenericEvent) bool {
228-
return processIfNotExternallyManaged(logger.WithValues("predicate", "genericEvent"), e.Object)
228+
return processIfNotExternallyManaged(logger.WithValues("predicate", "ResourceIsNotExternallyManaged", "eventType", "generic"), e.Object)
229229
},
230230
}
231231
}
@@ -246,16 +246,16 @@ func processIfNotExternallyManaged(logger logr.Logger, obj client.Object) bool {
246246
func ResourceIsTopologyOwned(logger logr.Logger) predicate.Funcs {
247247
return predicate.Funcs{
248248
UpdateFunc: func(e event.UpdateEvent) bool {
249-
return processIfTopologyOwned(logger.WithValues("predicate", "updateEvent"), e.ObjectNew)
249+
return processIfTopologyOwned(logger.WithValues("predicate", "ResourceIsTopologyOwned", "eventType", "update"), e.ObjectNew)
250250
},
251251
CreateFunc: func(e event.CreateEvent) bool {
252-
return processIfTopologyOwned(logger.WithValues("predicate", "createEvent"), e.Object)
252+
return processIfTopologyOwned(logger.WithValues("predicate", "ResourceIsTopologyOwned", "eventType", "create"), e.Object)
253253
},
254254
DeleteFunc: func(e event.DeleteEvent) bool {
255-
return processIfTopologyOwned(logger.WithValues("predicate", "deleteEvent"), e.Object)
255+
return processIfTopologyOwned(logger.WithValues("predicate", "ResourceIsTopologyOwned", "eventType", "delete"), e.Object)
256256
},
257257
GenericFunc: func(e event.GenericEvent) bool {
258-
return processIfTopologyOwned(logger.WithValues("predicate", "genericEvent"), e.Object)
258+
return processIfTopologyOwned(logger.WithValues("predicate", "ResourceIsTopologyOwned", "eventType", "generic"), e.Object)
259259
},
260260
}
261261
}

0 commit comments

Comments
 (0)