tasks

Documentation

Index

• type BackupTask
  • func NewBackupTask(sender mail.Mailer, repo *storage.ReadingRepository, label string) BackupTask
  • func (b BackupTask) Run()
  • func (b BackupTask) String() string
• type NotificationMailData
• type NotificationTask
  • func NewNotificationTask(sender mail.Mailer, repo storage.ReadingsLastDateLoader, ...) NotificationTask
  • func (n NotificationTask) Run()
• type Task
• type TaskFactory
• type TaskManager
  • func NewTaskManager() TaskManager
  • func (t *TaskManager) RegisterAndStartCronTask(tasks ...Task)

Types

type BackupTask

type BackupTask struct {
	// contains filtered or unexported fields
}

func NewBackupTask

func NewBackupTask(sender mail.Mailer, repo *storage.ReadingRepository, label string) BackupTask

func (BackupTask) Run

func (b BackupTask) Run()

func (BackupTask) String

func (b BackupTask) String() string

type NotificationMailData

type NotificationMailData struct {
	URL  string
	Days uint16
}

type NotificationTask

type NotificationTask struct {
	// contains filtered or unexported fields
}

func NewNotificationTask

func NewNotificationTask(sender mail.Mailer, repo storage.ReadingsLastDateLoader, config config.NotificationTaskConfig, label string) NotificationTask

func (NotificationTask) Run

func (n NotificationTask) Run()

type Task

type Task struct {
	Factory              TaskFactory
	Description          string
	SchedulingDefinition string
}

type TaskFactory

type TaskFactory func() cron.Job

type TaskManager

type TaskManager struct {
	// contains filtered or unexported fields
}

func NewTaskManager

func NewTaskManager() TaskManager

func (*TaskManager) RegisterAndStartCronTask

func (t *TaskManager) RegisterAndStartCronTask(tasks ...Task)