func()

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
}