Merge pull request #20 from datainfrahq/Fix-19-Lookup

Fix-19-Lookup

go.mod

@@ -3,6 +3,7 @@ module github.com/datainfrahq/operator-runtime
 go 1.19
 
 require (
+	github.com/go-logr/logr v1.2.3
 	k8s.io/api v0.26.1
 	k8s.io/apimachinery v0.26.2
 	k8s.io/client-go v0.26.1
@@ -13,7 +14,6 @@ require (
 	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/emicklei/go-restful/v3 v3.9.0 // indirect
 	github.com/evanphx/json-patch/v5 v5.6.0 // indirect
-	github.com/go-logr/logr v1.2.3 // indirect
 	github.com/go-openapi/jsonpointer v0.19.5 // indirect
 	github.com/go-openapi/jsonreference v0.20.0 // indirect
 	github.com/go-openapi/swag v0.19.14 // indirect

utils/utils.go

@@ -4,10 +4,17 @@ import (
 	"crypto/sha1"
 	"encoding/base64"
 	"encoding/json"
+	"os"
+	"time"
 
+	"github.com/go-logr/logr"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 )
 
+const (
+	ReconcileWait string = "RECONCILE_WAIT"
+)
+
 type ConfigMapHash struct {
 	Object client.Object
 }
@@ -69,3 +76,18 @@ func unique[T comparable](s []T) []T {
 	}
 	return result
 }
+
+func LookupReconcileTime(log logr.Logger) time.Duration {
+	val, exists := os.LookupEnv(ReconcileWait)
+	if !exists {
+		return time.Second * 10
+	} else {
+		v, err := time.ParseDuration(val)
+		if err != nil {
+			log.Error(err, err.Error())
+			// Exit Program if not valid
+			os.Exit(1)
+		}
+		return v
+	}
+}