feat: support later funcs

container/container.go

@@ -75,3 +75,18 @@ func (p Providers) Provide(config *viper.Viper) error {
 	}
 	return nil
 }
+
+// laters for run later funcs
+var later []func() error
+
+func Later(f func() error) {
+	later = append(later, f)
+}
+
+func RunLaterFuncs() {
+	for _, f := range later {
+		if err := f(); err != nil {
+			log.Fatal(err)
+		}
+	}
+}

contracts/cron_job.go

@@ -5,9 +5,19 @@ import (
 )
 
 type CronJob interface {
-	Kind() string
+	Args() []CronJobArg
-	Periodic() river.PeriodicSchedule
+}
-	JobArgs() river.JobArgs
+
-	InsertOpts() river.InsertOpts
+type JobArgs interface {
-	RunOnStart() bool
+	river.JobArgs
+	river.JobArgsWithInsertOpts
+
+	UniqueID() string
+}
+
+type CronJobArg struct {
+	RunOnStart       bool
+	PeriodicInterval river.PeriodicSchedule
+
+	Arg JobArgs
 }