Enable status subresource for policies.

After every backup, policy status is updated with details of
the just finished backup.

Makefile

@@ -8,12 +8,15 @@ DOCKER_KUBEDR_IMAGE_NAME_SHORT = kubedr
 DOCKER_KUBEDR_IMAGE_NAME_LONG = ${DOCKER_REGISTRY}${DOCKER_KUBEDR_IMAGE_NAME_SHORT}
 DOCKER_KUBEDR_IMAGE_NAME_LONG_DOCKERHUB = ${DOCKER_PREFIX}${DOCKER_KUBEDR_IMAGE_NAME_SHORT}
 
-DOCKER_KUBEDRUTIL_IMAGE_TAG ?= 0.2.2
+DOCKER_KUBEDRUTIL_IMAGE_TAG ?= 0.2.3
 DOCKER_KUBEDRUTIL_IMAGE_NAME_SHORT = kubedrutil
 DOCKER_KUBEDRUTIL_IMAGE_NAME_LONG = ${DOCKER_REGISTRY}${DOCKER_KUBEDRUTIL_IMAGE_NAME_SHORT}
 DOCKER_KUBEDRUTIL_IMAGE_NAME_LONG_DOCKERHUB = ${DOCKER_PREFIX}${DOCKER_KUBEDRUTIL_IMAGE_NAME_SHORT}
 
-build: docker_build go_build
+build: manifests docker_build go_build
+
+manifests:
+	cd ${DOCKER_DIR_BASE} && make manifests
 
 docker_build:
 	cd ${DOCKER_DIR_BASE} && \

kubedr/api/v1alpha1/backuplocation_types.go

@@ -41,12 +41,12 @@ type BackupLocationSpec struct {
 type BackupLocationStatus struct {
 	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
 	// Important: Run "make" to regenerate code after modifying this file
-	InitStatus string `json:"initStatus,omitempty"`
+	InitStatus string `json:"initStatus"`
 
 	// +kubebuilder:validation:Optional
-	InitErrorMessage string `json:"initErrorMessage,omitempty"`
+	InitErrorMessage string `json:"initErrorMessage"`
 
-	InitTime string `json:"initTime,omitempty"`
+	InitTime string `json:"initTime"`
 }
 
 // +kubebuilder:object:root=true

kubedr/api/v1alpha1/metadatabackuppolicy_types.go

@@ -18,6 +18,7 @@ package v1alpha1
 
 import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/api/resource"
 )
 
 // EDIT THIS FILE!  THIS IS SCAFFOLDING FOR YOU TO OWN!
@@ -66,11 +67,33 @@ type MetadataBackupPolicySpec struct {
 
 // MetadataBackupPolicyStatus defines the observed state of MetadataBackupPolicy
 type MetadataBackupPolicyStatus struct {
-	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
-	// Important: Run "make" to regenerate code after modifying this file
+	BackupTime   string `json:"backupTime"`
+	BackupStatus string `json:"backupStatus"`
+
+	// +kubebuilder:validation:Optional
+	BackupErrorMessage string `json:"backupErrorMessage"`
+
+	// +kubebuilder:validation:Optional
+	FilesNew uint `json:"filesNew"`
+
+	// +kubebuilder:validation:Optional
+	FilesChanged uint `json:"filesChanged"`
+
+	// +kubebuilder:validation:Optional
+	DataAdded uint64 `json:"dataAdded"`
+
+	// +kubebuilder:validation:Optional
+	TotalBytesProcessed uint64 `json:"totalBytesProcessed"`
+
+	// +kubebuilder:validation:Optional
+	TotalDurationSecs resource.Quantity `json:"totalDurationSecs"`
+
+	// +kubebuilder:validation:Optional
+	SnapshotID string `json:"snapshotId"`
 }
 
 // +kubebuilder:object:root=true
+// +kubebuilder:subresource:status
 
 // MetadataBackupPolicy is the Schema for the metadatabackuppolicies API
 type MetadataBackupPolicy struct {

kubedr/config/crd/bases/kubedr.catalogicsoftware.com_backuplocations.yaml

@@ -60,9 +60,11 @@ spec:
                 of cluster Important: Run "make" to regenerate code after modifying
                 this file'
               type: string
+            initTime:
+              type: string
           required:
-          - initErrorMessage
           - initStatus
+          - initTime
           type: object
       type: object
   version: v1alpha1

kubedr/config/crd/bases/kubedr.catalogicsoftware.com_metadatabackuppolicies.yaml

@@ -15,6 +15,8 @@ spec:
     plural: metadatabackuppolicies
     singular: metadatabackuppolicy
   scope: ""
+  subresources:
+    status: {}
   validation:
     openAPIV3Schema:
       description: MetadataBackupPolicy is the Schema for the metadatabackuppolicies
@@ -72,6 +74,30 @@ spec:
           type: object
         status:
           description: MetadataBackupPolicyStatus defines the observed state of MetadataBackupPolicy
+          properties:
+            backupErrorMessage:
+              type: string
+            backupStatus:
+              type: string
+            backupTime:
+              type: string
+            dataAdded:
+              format: int64
+              type: integer
+            filesChanged:
+              type: integer
+            filesNew:
+              type: integer
+            snapshotId:
+              type: string
+            totalBytesProcessed:
+              format: int64
+              type: integer
+            totalDurationSecs:
+              type: string
+          required:
+          - backupStatus
+          - backupTime
           type: object
       type: object
   version: v1alpha1

kubedr/controllers/metadatabackuppolicy_controller.go

@@ -47,6 +47,8 @@ type MetadataBackupPolicyReconciler struct {
 func (r *MetadataBackupPolicyReconciler) newPolicy(policy *kubedrv1alpha1.MetadataBackupPolicy,
 	namespace string, cronJobName string) (ctrl.Result, error) {
 
+	r.setStatus(policy)
+
 	backupCronjob, err := r.buildBackupCronjob(policy, namespace, cronJobName)
 	if err != nil {
 		r.Log.Error(err, "Error in creating backup cronjob")
@@ -132,6 +134,16 @@ func (r *MetadataBackupPolicyReconciler) processSpec(policy *kubedrv1alpha1.Meta
 	return r.processUpdate(policy, &cronJob)
 }
 
+func (r *MetadataBackupPolicyReconciler) setStatus(policy *kubedrv1alpha1.MetadataBackupPolicy) {
+	policy.Status.BackupStatus = "Initializing"
+	policy.Status.BackupTime = metav1.Now().String()
+
+	r.Log.Info("Updating status...")
+	if err := r.Status().Update(context.Background(), policy); err != nil {
+		r.Log.Error(err, "unable to update policy status")
+	}
+}
+
 // +kubebuilder:rbac:groups=kubedr.catalogicsoftware.com,resources=metadatabackuppolicies,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups=kubedr.catalogicsoftware.com,resources=metadatabackuppolicies/status,verbs=get;update;patch
 // +kubebuilder:rbac:groups=batch,resources=cronjobs,verbs=create;get;list;update;patch;delete;watch