feat: rm.IsSynced returns requeueError when false

This changes introduce a new field in generator.yaml SyncedConfig, which
lets us define custom reuqueue duration. If it is not defined, the
duration will default to the DefaultSyncPeriod

Author: michaelhtm

pkg/config/resource.go

@@ -152,6 +152,8 @@ type SyncedCondition struct {
 	Path *string `json:"path"`
 	// In contains a list of possible values `Path` should be equal to.
 	In []string `json:"in"`
+	// RequeueError custom SyncPeriod in seconds
+	RequeueTime *int `json:"requeueTime,omitempty`
 }
 
 // HooksConfig instructs the code generator how to inject custom callback hooks

pkg/generate/code/synced.go

@@ -75,11 +75,17 @@ func ResourceIsSynced(
 			msg := fmt.Sprintf("cannot find top level field of path '%s': %v", *condCfg.Path, err)
 			panic(msg)
 		}
+		notSyncedErr := ""
+		if condCfg.RequeueTime != nil {
+			notSyncedErr = fmt.Sprintf("ackrequeue.NeededAfter(fmt.Errorf(\"requeing until resource status is %v\"), time.Duration(%d)*time.Second)", condCfg.In, *condCfg.RequeueTime)
+		} else {
+			notSyncedErr = fmt.Sprintf("ackrequeue.Needed(fmt.Errorf(\"requeing until resource status is %v\"))", condCfg.In)
+		}
 		candidatesVarName := fmt.Sprintf("%sCandidates", field.Names.CamelLower)
 		if fp.Size() == 2 {
-			out += scalarFieldEqual(resVarName, candidatesVarName, field.ShapeRef.GoTypeElem(), condCfg)
+			out += scalarFieldEqual(resVarName, candidatesVarName, field.ShapeRef.GoTypeElem(), condCfg, notSyncedErr)
 		} else {
-			out += fieldPathSafeEqual(resVarName, candidatesVarName, field, condCfg)
+			out += fieldPathSafeEqual(resVarName, candidatesVarName, field, condCfg, notSyncedErr)
 		}
 	}
 
@@ -118,6 +124,7 @@ func scalarFieldEqual(
 	candidatesVarName string,
 	goType string,
 	condCfg ackgenconfig.SyncedCondition,
+	notSyncedErr string,
 ) string {
 	out := ""
 	fieldPath := fmt.Sprintf("%s.%s", resVarName, *condCfg.Path)
@@ -156,7 +163,7 @@ func scalarFieldEqual(
 	)
 
 	// return false, nil
-	out += "\t\treturn false, nil\n"
+	out += fmt.Sprintf("\t\treturn false, %s\n", notSyncedErr)
 	// }
 	out += "\t}\n"
 	return out
@@ -168,6 +175,7 @@ func fieldPathSafeEqual(
 	candidatesVarName string,
 	field *model.Field,
 	condCfg ackgenconfig.SyncedCondition,
+	notSyncedErr string,
 ) string {
 	out := ""
 	rootPath := fmt.Sprintf("%s.%s", resVarName, strings.Split(*condCfg.Path, ".")[0])
@@ -187,11 +195,11 @@ func fieldPathSafeEqual(
 		// if r.ko.Spec.ProvisionedThroughput == nil
 		out += fmt.Sprintf("\tif %s == nil {\n", subFieldPath)
 		// return false, nil
-		out += "\t\treturn false, nil\n"
+		out += fmt.Sprintf("\t\treturn false, %s\n", notSyncedErr)
 		// }
 		out += "\t}\n"
 	}
-	out += scalarFieldEqual(resVarName, candidatesVarName, shapes[len(shapes)-1].GoTypeElem(), condCfg)
+	out += scalarFieldEqual(resVarName, candidatesVarName, shapes[len(shapes)-1].GoTypeElem(), condCfg, notSyncedErr)
 	return out
 }