in controllers/codebaseimagestream/codebaseimagestream_controller.go [34:72]
func (r *ReconcileCodebaseImageStream) SetupWithManager(mgr ctrl.Manager) error {
p := predicate.Funcs{
CreateFunc: func(e event.CreateEvent) bool {
return false
},
UpdateFunc: func(e event.UpdateEvent) bool {
oo, ok := e.ObjectOld.(*codebaseApi.CodebaseImageStream)
if !ok {
return false
}
on, ok := e.ObjectNew.(*codebaseApi.CodebaseImageStream)
if !ok {
return false
}
if codebasepredicate.PauseAnnotationChanged(oo, on) {
return true
}
if !reflect.DeepEqual(oo.Spec.Tags, on.Spec.Tags) && on.ObjectMeta.Labels != nil {
return true
}
return false
},
}
pause := codebasepredicate.NewPause(r.log)
err := ctrl.NewControllerManagedBy(mgr).
For(&codebaseApi.CodebaseImageStream{}, builder.WithPredicates(pause, p)).
Complete(r)
if err != nil {
return fmt.Errorf("failed to build CodebaseImageStream controller: %w", err)
}
return nil
}