Deployment Reconcile Loop

deployment_reconcile.go

func (r *DeploymentReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error) {
	ctx := context.Background()
	log := r.Log.WithValues("deployment", req.NamespacedName)

	dep := &appsv1.Deployment{}
	err := r.Get(ctx, req.NamespacedName, dep)
	if err != nil {
		if errors.IsNotFound(err) {
			// Request object not found, could have been deleted after reconcile request.
			// Owned objects are automatically garbage collected. For additional cleanup logic use finalizers.
			// Return and don't requeue
			log.Info("Deployment resource not found. Ignoring since object must be deleted")
			return ctrl.Result{}, nil
		}

		// Error reading the object - requeue the request.
		log.Error(err, "Failed to get deployment")
		return ctrl.Result{}, err
	}

	bucketCloud := abv1.BucketCloud(dep.Annotations[bucketCloudKey])
	if bucketCloud == "" {
		// no autobucket annotation
		return ctrl.Result{}, nil
	}

	// Check if the bucket object already exists, if not create a new one
	bucket := &abv1.Bucket{}
	err = r.Get(ctx, types.NamespacedName{Name: dep.Name, Namespace: dep.Namespace}, bucket)
	if err != nil && errors.IsNotFound(err) {
		// Define new
		bucket, err := r.bucketForDeployment(dep)
		if err != nil {
			log.Error(err, "Failed to build new Bucket", "Bucket.Name", dep.Name)
			return ctrl.Result{}, err
		}

		log.Info("Creating a new Bucket", "Bucket.Name", bucket.Name)
		err = r.Create(ctx, bucket)
		if err != nil {
			log.Error(err, "Failed to create new Bucket", "Bucket.Name", bucket.Name)
			return ctrl.Result{}, err
		}

		// created successfully - return and requeue
		return ctrl.Result{Requeue: true}, nil
	} else if err != nil {
		log.Error(err, "Failed to get Bucket")
		return ctrl.Result{}, err
	}

	// check if bucket ondelete policy must be updated
	bucketOnDeletePolicy := abv1.BucketOnDeletePolicy(dep.Annotations[bucketOnDeletePolicyKey])
	if bucketOnDeletePolicy != bucket.Spec.OnDeletePolicy {
		bucket.Spec.OnDeletePolicy = bucketOnDeletePolicy

		log.Info("Updating Bucket OnDeletePolicy", "Bucket.Name", bucket.Name, "Bucket.OnDeletePolicy", bucketOnDeletePolicy)

		if err := r.Update(context.Background(), bucket); err != nil {
			log.Error(err, "Failed to update bucket")
			return ctrl.Result{}, err
		}

		// updated successfully - return and requeue
		return ctrl.Result{Requeue: true}, nil
	}

	return ctrl.Result{}, nil
}