diff --git a/contracts/cron_job.go b/contracts/cron_job.go index b17ef0e..4c39022 100644 --- a/contracts/cron_job.go +++ b/contracts/cron_job.go @@ -5,9 +5,18 @@ import ( ) type CronJob interface { - Kind() string - Periodic() river.PeriodicSchedule - JobArgs() river.JobArgs - InsertOpts() river.InsertOpts - RunOnStart() bool + Args() []CronJobArg +} + +type CronJobArgInterface interface { + river.JobArgs + river.JobArgsWithInsertOpts +} + +type CronJobArg struct { + Kind string + RunOnStart bool + PeriodicInterval river.PeriodicSchedule + + Arg CronJobArgInterface }