Reconcilation

cyclops-ctrl/api/v1alpha1/module_types.go

@@ -65,7 +65,9 @@ type ReconciliationStatus struct {
 	// +kubebuilder:validation:Optional
 	Reason string `json:"reason,omitempty"`
 	// +kubebuilder:validation:Optional
-	Errors []string `json:"errors"`
+	Errors     []string `json:"errors"`
+	// +kubebuilder:validation:Optional
+	FinishedAt string   `json:"finishedAt,omitempty"`
 }
 
 type GroupVersionResource struct {
@@ -94,6 +96,8 @@ type HistoryEntry struct {
 	Generation  int64                `json:"generation"`
 	TemplateRef HistoryTemplateRef   `json:"template"`
 	Values      apiextensionsv1.JSON `json:"values"`
+	// +kubebuilder:validation:Optional
+	FinishedAt  string               `json:"finishedAt,omitempty"`
 }
 
 //+kubebuilder:object:root=true

cyclops-ctrl/config/crd/bases/cyclops-ui.com_modules.yaml

@@ -29,6 +29,8 @@ spec:
           history:
             items:
               properties:
+                finishedAt:
+                  type: string
                 generation:
                   format: int64
                   type: integer
@@ -113,6 +115,8 @@ spec:
                     items:
                       type: string
                     type: array
+                  finishedAt:
+                    type: string
                   reason:
                     type: string
                   status:

cyclops-ctrl/internal/modulecontroller/module_controller.go

@@ -424,9 +424,10 @@ func (r *ModuleReconciler) setStatus(
 
 	module.Status = cyclopsv1alpha1.ModuleStatus{
 		ReconciliationStatus: cyclopsv1alpha1.ReconciliationStatus{
-			Status: status,
-			Reason: reason,
-			Errors: installErrors,
+			Status:     status,
+			Reason:     reason,
+			Errors:     installErrors,
+			FinishedAt: time.Now().Format(time.RFC3339), // Convert time to string format
 		},
 		ManagedGVRs:             r.mergeChildrenGVRs(module.Status.ManagedGVRs, childrenResources),
 		TemplateResolvedVersion: templateResolvedVersion,

cyctl/cmd/reconcile.go

@@ -0,0 +1,59 @@
+package cmd
+
+import (
+	"fmt"
+
+	"github.com/cyclops-ui/cyclops/cyclops-ctrl/api/v1alpha1/client"
+	"github.com/cyclops-ui/cycops-cyctl/internal/kubeconfig"
+	"github.com/spf13/cobra"
+	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"time"
+)
+
+func reconcileModule(clientset *client.CyclopsV1Alpha1Client, moduleName string) {
+	module, err := clientset.Modules("cyclops").Get(moduleName)
+	if err != nil {
+		fmt.Println("Failed to fetch the module ", err)
+		return
+	}
+	annotations := module.GetAnnotations()
+	if annotations == nil {
+		annotations = make(map[string]string)
+	}
+	annotations["cyclops/reconciled-at"] = time.Now().Format(time.RFC3339)
+	module.SetAnnotations(annotations)
+	module.TypeMeta = v1.TypeMeta{
+		APIVersion: "cyclops-ui.com/v1alpha1",
+		Kind:       "Module",
+	}
+
+	_, err = clientset.Modules("cyclops").Update(module)
+	if err != nil {
+		fmt.Println("failed to update module: ", err)
+		return
+	}
+	fmt.Printf("successfully reconciled %v", moduleName)
+
+}
+
+var (
+	reconcileExample = `# Reconcile the Module 
+	cyctl reconcile <modulename>`
+)
+
+var reconcileCMD = &cobra.Command{
+	Use:     "reconcile",
+	Short:   "Will reconcile the Module and update the current TimeStamp",
+	Long:    "Will reconcile the Module and update the current TimeStamp",
+	Example: reconcileExample,
+	Args:    cobra.ExactArgs(1),
+	Run: func(cmd *cobra.Command, args []string) {
+		moduleName := args[0]
+		reconcileModule(kubeconfig.Moduleset, moduleName)
+	},
+}
+
+func init() {
+	RootCmd.AddCommand(reconcileCMD)
+
+}