in controllers/packagebundle_controller.go [100:124]
func (r *PackageBundleReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
r.Log.V(6).Info("Reconcile:", "bundle", req.NamespacedName)
pkgBundle := &api.PackageBundle{}
if err := r.Get(ctx, req.NamespacedName, pkgBundle); err != nil {
if client.IgnoreNotFound(err) != nil {
return ctrl.Result{}, err
}
// ignore deletes
return ctrl.Result{}, nil
}
r.Log.Info("Add/ProcessBundle:", "bundle", req.NamespacedName)
change, err := r.bundleManager.ProcessBundle(ctx, pkgBundle)
if err != nil {
return ctrl.Result{}, fmt.Errorf("package bundle update: %s", err)
}
if change {
err = r.Status().Update(ctx, pkgBundle)
if err != nil {
return ctrl.Result{}, err
}
}
return ctrl.Result{}, nil
}