Files
atom/contracts/cron_job.go
2025-03-21 16:54:26 +08:00

24 lines
308 B
Go

package contracts
import (
"github.com/riverqueue/river"
)
type CronJob interface {
Args() []CronJobArg
}
type JobArgs interface {
river.JobArgs
river.JobArgsWithInsertOpts
UniqueID() string
}
type CronJobArg struct {
RunOnStart bool
PeriodicInterval river.PeriodicSchedule
Arg JobArgs
}