in controllers/gerritgroupmember/controller.go [86:127]
func (r *Reconcile) Reconcile(ctx context.Context, request reconcile.Request) (result reconcile.Result, resError error) {
reqLogger := r.log.WithValues("Request.Namespace", request.Namespace, "Request.Name", request.Name)
reqLogger.V(2).Info("Reconciling GerritGroupMember has been started")
var instance gerritApi.GerritGroupMember
if err := r.client.Get(context.TODO(), request.NamespacedName, &instance); err != nil {
if k8sErrors.IsNotFound(err) {
return
}
return reconcile.Result{}, errors.Wrap(err, "unable to get GerritGroupMember instance")
}
defer func() {
if err := r.client.Status().Update(context.Background(), &instance); err != nil {
reqLogger.Error(err, "unable to update instance status")
}
}()
if err := r.tryToReconcile(ctx, &instance); err != nil {
reqLogger.Error(err, "unable to reconcile GerritGroupMember")
instance.Status.Value = err.Error()
expRequeueTime := helper.SetFailureCount(&instance)
constTimeout, isSet := getSyncInterval(syncIntervalEnv)
if !isSet {
reqLogger.Info("Unable to get sync interval from env. Requeue time will be set using the exponential formula")
reqLogger.Info("Requeue time", "time", expRequeueTime.String())
return reconcile.Result{RequeueAfter: expRequeueTime}, nil
}
reqLogger.Info("Requeue time", "time", constTimeout.String())
return reconcile.Result{RequeueAfter: constTimeout}, nil
}
helper.SetSuccessStatus(&instance)
return
}