backgroundtasks

Jul 18, 2021

Changes in this version

+ var TypeIBackgroundTasks = di.GetInterfaceReflectType((*IBackgroundTasks)(nil))

+ var TypeIJobsProvider = di.GetInterfaceReflectType((*IJobsProvider)(nil))

type OneTimeJob

+ func NewOneTimeJob(job cron.Job, delay time.Duration) *OneTimeJob

+ type OneTimeJobs []*OneTimeJob

+ func NewOneTimeJobs(jobs ...*OneTimeJob) OneTimeJobs

type ScheduledJob

+ func NewScheduledJob(job cron.Job, schedule string) *ScheduledJob

+ type ScheduledJobs []*ScheduledJob

+ func NewScheduledJobs(jobs ...*ScheduledJob) ScheduledJobs

Jul 17, 2021

Changes in this version

+ type IJobsProvider interface

+ GetOneTimeJobs func() []*OneTimeJob

+ GetScheduledJobs func() []*ScheduledJob

+ type OneTimeJob struct

+ Delay time.Duration

+ Job cron.Job

+ type ReminderEmails struct

+ func (e ReminderEmails) Run()

+ type ScheduledJob struct

+ Job cron.Job

+ Schedule string

Jul 12, 2021

Changes in this version

+ func AddBackgroundTasks(builder *di.Builder)

+ func AddCounterTaskConsumer(builder *di.Builder)

+ func GetLocalCounter() int32

+ func IncrLocalCounter()

+ type IBackgroundTasks interface

+ func GetBackgroundTasksFromContainer(ctn di.Container) IBackgroundTasks

+ type IConsumer interface

+ GetTaskMessages func() []*taskq.Message