Expose resync-period as flag

Author: tamalsaha

run.go

@@ -3,6 +3,7 @@ package cmds
 import (
 	"fmt"
 	"net/http"
+	"time"
 
 	stringz "github.com/appscode/go/strings"
 	"github.com/appscode/log"
@@ -30,8 +31,9 @@ func NewCmdRun(version string) *cobra.Command {
 	var (
 		masterURL      string
 		kubeconfigPath string
-		tag            string = stringz.Val(version, "canary")
-		address        string = ":56790"
+		tag            string        = stringz.Val(version, "canary")
+		address        string        = ":56790"
+		resyncPeriod   time.Duration = 5 * time.Minute
 	)
 
 	cmd := &cobra.Command{
@@ -51,7 +53,7 @@ func NewCmdRun(version string) *cobra.Command {
 			stashClient = scs.NewForConfigOrDie(config)
 			crdClient := apiextensionsclient.NewForConfigOrDie(config)
 
-			ctrl := controller.New(kubeClient, crdClient, stashClient, tag)
+			ctrl := controller.New(kubeClient, crdClient, stashClient, tag, resyncPeriod)
 			err = ctrl.Setup()
 			if err != nil {
 				log.Fatalln(err)
@@ -80,6 +82,7 @@ func NewCmdRun(version string) *cobra.Command {
 	cmd.Flags().StringVar(&kubeconfigPath, "kubeconfig", kubeconfigPath, "Path to kubeconfig file with authorization information (the master location is set by the master flag).")
 	cmd.Flags().StringVar(&address, "address", address, "Address to listen on for web interface and telemetry.")
 	cmd.Flags().StringVar(&scratchDir, "scratch-dir", scratchDir, "Directory used to store temporary files. Use an `emptyDir` in Kubernetes.")
+	cmd.Flags().DurationVar(&resyncPeriod, "resync-period", resyncPeriod, "If non-zero, will re-list this often. Otherwise, re-list will be delayed aslong as possible (until the upstream source closes the watch or times out.")
 
 	return cmd
 }

schedule.go

@@ -4,6 +4,7 @@ import (
 	"io/ioutil"
 	"os"
 	"strings"
+	"time"
 
 	"github.com/appscode/log"
 	rcs "github.com/appscode/stash/client/clientset"
@@ -27,6 +28,7 @@ func NewCmdSchedule() *cobra.Command {
 			ScratchDir:     "/tmp",
 			PushgatewayURL: "http://stash-operator.kube-system.svc:56789",
 			PodLabelsPath:  "/etc/stash/labels",
+			ResyncPeriod:   5 * time.Minute,
 		}
 	)
 
@@ -130,6 +132,7 @@ func NewCmdSchedule() *cobra.Command {
 	cmd.Flags().StringVar(&opt.ResticName, "restic-name", opt.ResticName, "Name of the Restic used as configuration.")
 	cmd.Flags().StringVar(&opt.ScratchDir, "scratch-dir", opt.ScratchDir, "Directory used to store temporary files. Use an `emptyDir` in Kubernetes.")
 	cmd.Flags().StringVar(&opt.PushgatewayURL, "pushgateway-url", opt.PushgatewayURL, "URL of Prometheus pushgateway used to cache backup metrics")
+	cmd.Flags().DurationVar(&opt.ResyncPeriod, "resync-period", opt.ResyncPeriod, "If non-zero, will re-list this often. Otherwise, re-list will be delayed aslong as possible (until the upstream source closes the watch or times out.")
 
 	return cmd
 }