diff --git a/controllers/drupalsite_controller.go b/controllers/drupalsite_controller.go
index 6ffa0d5af7a708d60396f3d3453351b89ebc0b59..cc94a9832000c80aa0865725f8331b96fa38fba4 100644
--- a/controllers/drupalsite_controller.go
+++ b/controllers/drupalsite_controller.go
@@ -125,7 +125,8 @@ func (r *DrupalSiteReconciler) Reconcile(ctx context.Context, req ctrl.Request)
// Create route
// Ensure all primary resources
- if transientErr := r.ensureResources(drupalSite, log); transientErr != nil {
+ if transientErrs := r.ensureResources(drupalSite, log); transientErrs != nil {
+ transientErr := concat(transientErrs)
setNotReady(drupalSite, transientErr)
return handleTransientErr(transientErr, "%v while creating the resources")
}
diff --git a/controllers/drupalsite_resources.go b/controllers/drupalsite_resources.go
index 2c10a0a4fc8aad77eeceea5f5a7e96952af04473..348239dbbde18d6177bb750236bb404fce5b9ec6 100644
--- a/controllers/drupalsite_resources.go
+++ b/controllers/drupalsite_resources.go
@@ -106,71 +106,71 @@ func ensureSpecFinalizer(drp *webservicesv1a1.DrupalSite, log logr.Logger) (upda
ensureResources ensures the presence of all the resources that the DrupalSite needs to serve content, apart from the ingress Route.
This includes BuildConfigs/ImageStreams, DB, PVC, PHP/Nginx deployment + service, site install job.
*/
-func (r *DrupalSiteReconciler) ensureResources(drp *webservicesv1a1.DrupalSite, log logr.Logger) (transientErr reconcileError) {
+func (r *DrupalSiteReconciler) ensureResources(drp *webservicesv1a1.DrupalSite, log logr.Logger) (transientErrs []reconcileError) {
ctx := context.TODO()
// 1. BuildConfigs and ImageStreams
if len(drp.Spec.Environment.ExtraConfigRepo) > 0 {
if transientErr := r.ensureResourceX(ctx, drp, "is_s2i", log); transientErr != nil {
- return transientErr.Wrap("%v: for S2I SiteBuilder ImageStream")
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for S2I SiteBuilder ImageStream"))
}
if transientErr := r.ensureResourceX(ctx, drp, "bc_s2i", log); transientErr != nil {
- return transientErr.Wrap("%v: for S2I SiteBuilder BuildConfig")
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for S2I SiteBuilder BuildConfig"))
}
}
if transientErr := r.ensureResourceX(ctx, drp, "is_php", log); transientErr != nil {
- return transientErr.Wrap("%v: for PHP ImageStream")
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for PHP ImageStream"))
}
if transientErr := r.ensureResourceX(ctx, drp, "is_nginx", log); transientErr != nil {
- return transientErr.Wrap("%v: for Nginx ImageStream")
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for Nginx ImageStream"))
}
if transientErr := r.ensureResourceX(ctx, drp, "bc_php", log); transientErr != nil {
- return transientErr.Wrap("%v: for PHP BuildConfig")
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for PHP BuildConfig"))
}
if transientErr := r.ensureResourceX(ctx, drp, "bc_nginx", log); transientErr != nil {
- return transientErr.Wrap("%v: for Nginx BuildConfig")
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for Nginx BuildConfig"))
}
// 2. Data layer
if transientErr := r.ensureResourceX(ctx, drp, "pvc_drupal", log); transientErr != nil {
- return transientErr.Wrap("%v: for Drupal PVC")
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for Drupal PVC"))
}
if transientErr := r.ensureResourceX(ctx, drp, "pvc_mysql", log); transientErr != nil {
- return transientErr.Wrap("%v: for MySQL PVC")
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for MySQL PVC"))
}
- if transientErr := r.ensureResourceX(ctx, drp, "dc_mysql", log); transientErr != nil {
- return transientErr.Wrap("%v: for Mysql DC")
+ if transientErr := r.ensureResourceX(ctx, drp, "deploy_mysql", log); transientErr != nil {
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for Mysql DC"))
}
if transientErr := r.ensureResourceX(ctx, drp, "svc_mysql", log); transientErr != nil {
- return transientErr.Wrap("%v: for Mysql SVC")
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for Mysql SVC"))
}
if transientErr := r.ensureResourceX(ctx, drp, "cm_mysql", log); transientErr != nil {
- return transientErr.Wrap("%v: for MySQL CM")
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for MySQL CM"))
}
// 3. Serving layer
if transientErr := r.ensureResourceX(ctx, drp, "cm_php", log); transientErr != nil {
- return transientErr.Wrap("%v: for PHP-FPM CM")
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for PHP-FPM CM"))
}
if transientErr := r.ensureResourceX(ctx, drp, "cm_nginx", log); transientErr != nil {
- return transientErr.Wrap("%v: for Nginx CM")
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for Nginx CM"))
}
- if transientErr := r.ensureResourceX(ctx, drp, "dc_drupal", log); transientErr != nil {
- return transientErr.Wrap("%v: for Drupal DC")
+ if transientErr := r.ensureResourceX(ctx, drp, "deploy_drupal", log); transientErr != nil {
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for Drupal DC"))
}
if transientErr := r.ensureResourceX(ctx, drp, "svc_nginx", log); transientErr != nil {
- return transientErr.Wrap("%v: for Nginx SVC")
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for Nginx SVC"))
}
// 4. Ingress
if transientErr := r.ensureResourceX(ctx, drp, "site_install_job", log); transientErr != nil {
- return transientErr.Wrap("%v: for site install Job")
+ transientErrs = append(transientErrs, transientErr.Wrap("%v: for site install Job"))
}
- return nil
+ return transientErrs
}
// ensureIngressResources ensures the presence of the Route to access the website from the outside world
@@ -1088,7 +1088,7 @@ func updateConfigMapForMySQL(ctx context.Context, currentobject *corev1.ConfigMa
/*
ensureResourceX ensure the requested resource is created, with the following valid values
- - dc_mysql: Deployment for MySQL
+ - deploy_mysql: Deployment for MySQL
- svc_mysql: Service for MySQL
- cm_mysql: Configmap for MySQL
- pvc_mysql: PersistentVolume for the MySQL
@@ -1101,7 +1101,7 @@ ensureResourceX ensure the requested resource is created, with the following val
- bc_s2i: BuildConfig for S2I sitebuilder
- bc_php: BuildConfig for PHP
- bc_nginx: BuildConfig for Nginx
- - dc_drupal: Deployment for Nginx & PHP-FPM
+ - deploy_drupal: Deployment for Nginx & PHP-FPM
- svc_nginx: Service for Nginx
- cm_php: ConfigMap for PHP-FPM
- cm_nginx: ConfigMap for Nginx
@@ -1175,7 +1175,7 @@ func (r *DrupalSiteReconciler) ensureResourceX(ctx context.Context, d *webservic
return newApplicationError(err, ErrClientK8s)
}
return nil
- case "dc_mysql":
+ case "deploy_mysql":
deploy := &appsv1.Deployment{ObjectMeta: metav1.ObjectMeta{Name: "drupal-mysql-" + d.Name, Namespace: d.Namespace}}
_, err := controllerruntime.CreateOrUpdate(ctx, r.Client, deploy, func() error {
log.Info("Ensuring Resource", "Kind", deploy.TypeMeta.Kind, "Resource.Namespace", deploy.Namespace, "Resource.Name", deploy.Name)
@@ -1186,7 +1186,7 @@ func (r *DrupalSiteReconciler) ensureResourceX(ctx context.Context, d *webservic
return newApplicationError(err, ErrClientK8s)
}
return nil
- case "dc_drupal":
+ case "deploy_drupal":
deploy := &appsv1.Deployment{ObjectMeta: metav1.ObjectMeta{Name: "drupal-" + d.Name, Namespace: d.Namespace}}
_, err := controllerruntime.CreateOrUpdate(ctx, r.Client, deploy, func() error {
log.Info("Ensuring Resource", "Kind", deploy.TypeMeta.Kind, "Resource.Namespace", deploy.Namespace, "Resource.Name", deploy.Name)
diff --git a/controllers/error_types.go b/controllers/error_types.go
index 78421d792ebef0eadf44318078b98be0e300ed74..db9029cd381102e9954fca528344fc380309ce26 100644
--- a/controllers/error_types.go
+++ b/controllers/error_types.go
@@ -24,6 +24,18 @@ type reconcileError interface {
Temporary() bool
}
+// concat concatenates the Error of each reconcileError and sets the result's errorCondition to the first condition
+func concat(errs []reconcileError) reconcileError {
+ if len(errs) == 0 {
+ return nil
+ }
+ sum := errors.New("")
+ for _, e := range errs {
+ sum = fmt.Errorf("%v\n%v", sum, e)
+ }
+ return newApplicationError(sum, errs[0].Unwrap())
+}
+
// applicationError wraps an error condition and gives it more context from where it occurred
type applicationError struct {
innerException error