backgroundtasks

Documentation

Index

• func AddBackgroundTasks(builder *di.Builder)
• func AddCounterTaskConsumer(builder *di.Builder)
• type IBackgroundTasks
  • func GetBackgroundTasksFromContainer(ctn di.Container) IBackgroundTasks
• type IJobsProvider
• type OneTimeJob
• type ReminderEmails
  • func (e ReminderEmails) Run()
• type ScheduledJob

Functions

func AddBackgroundTasks

func AddBackgroundTasks(builder *di.Builder)

AddBackgroundTasks adds service to the DI container

func AddCounterTaskConsumer

func AddCounterTaskConsumer(builder *di.Builder)

AddCounterTaskConsumer adds service to the DI container

Types

type IBackgroundTasks

type IBackgroundTasks interface {
}

func GetBackgroundTasksFromContainer

func GetBackgroundTasksFromContainer(ctn di.Container) IBackgroundTasks

type IJobsProvider

type IJobsProvider interface {
	GetScheduledJobs() []*ScheduledJob
	GetOneTimeJobs() []*OneTimeJob
}

type OneTimeJob

type OneTimeJob struct {
	// Job must support Run() func
	Job   cron.Job
	Delay time.Duration
}

type ReminderEmails

type ReminderEmails struct {
}

func (ReminderEmails) Run

func (e ReminderEmails) Run()

ReminderEmails.Run() will get triggered automatically.

type ScheduledJob

type ScheduledJob struct {
	// Job must support Run() func
	Job cron.Job
	// Schedule "* */5 * * * *","@every 1h30m10s","@midnight"
	Schedule string
}

ScheduledJob cron