setup reconciler

Author: easyCZ

components/usage/cmd/run.go

@@ -27,14 +27,14 @@ func run() *cobra.Command {
 		Run: func(cmd *cobra.Command, args []string) {
 			log.Init(ServiceName, Version, true, verbose)
 
-			log.Info("Hello world usage server")
-
-			ctrl := controller.New(controller.Config{})
-			err := ctrl.Start()
+			ctrl, err := controller.New("@every 1m", controller.ReconcilerFunc(controller.HelloWorldReconciler))
 			if err != nil {
-				log.WithError(err).Fatal("Failed to start controller.")
+				log.WithError(err).Fatal("Failed to initialize usage controller.")
 			}
 
+			ctrl.Start()
+			defer ctrl.Stop()
+
 			srv, err := baseserver.New("usage")
 			if err != nil {
 				log.WithError(err).Fatal("Failed to initialize server.")

components/usage/pkg/controller/controller.go

@@ -35,14 +35,19 @@ type Controller struct {
 }
 
 func (c *Controller) Start() {
-	log.
-		c.scheduler.Schedule(c.schedule, cron.FuncJob(func() {
+	log.Info("Starting usage controller.")
+
+	c.scheduler.Schedule(c.schedule, cron.FuncJob(func() {
+		log.Info("Starting usage reconciliation.")
+
 		c.runningJobs.Add(1)
 		defer c.runningJobs.Done()
 
 		err := c.reconciler.Reconcile()
 		if err != nil {
-			log.WithError(err).Errorf("Controller run failed.")
+			log.WithError(err).Errorf("Reconciliation run failed.")
+		} else {
+			log.Info("Completed usage reconciliation run without errors.")
 		}
 	}))
 
@@ -51,9 +56,11 @@ func (c *Controller) Start() {
 
 // Stop terminates the Controller and awaits for all running jobs to complete.
 func (c *Controller) Stop() {
+	log.Info("Stopping usage controller.")
 	// Stop any new jobs from running
 	c.scheduler.Stop()
 
+	log.Info("Awaiting existing reconciliation runs to complete..")
 	// Wait for existing jobs to finish
 	c.runningJobs.Wait()
 }

components/usage/pkg/controller/reconciler.go

@@ -4,6 +4,8 @@
 
 package controller
 
+import "github.com/gitpod-io/gitpod/common-go/log"
+
 type Reconciler interface {
 	Reconcile() error
 }
@@ -13,3 +15,8 @@ type ReconcilerFunc func() error
 func (f ReconcilerFunc) Reconcile() error {
 	return f()
 }
+
+func HelloWorldReconciler() error {
+	log.Info("Hello world reconciler!")
+	return nil
+}