schedule

Documentation

Index

• type ScheduledJob
  • func FromStoreToHandler(scheduledJobsStoreFormat []postgres.JobsSchedule) ([]ScheduledJob, error)
  • func GetScheduledJob(scheduledJobStoreFormat postgres.JobsSchedule) (ScheduledJob, error)
• type Scheduler
  • func NewScheduler(store storage.Store, metadataStore metadata.Store) Scheduler
• type Worker
  • func NewWorker(store storage.Store, executioner execution.Executioner, auditor audit.Auditor, ...) Worker

Types

type ScheduledJob

type ScheduledJob struct {
	ID                 string            `json:"id"`
	Name               string            `json:"name"`
	Args               map[string]string `json:"args"`
	NotificationEmails string            `json:"notification_emails"`
	Time               string            `json:"time"`
	Tags               string            `json:"tags"`
	Group              string            `json:"group_name"`
}

func FromStoreToHandler

func FromStoreToHandler(scheduledJobsStoreFormat []postgres.JobsSchedule) ([]ScheduledJob, error)

func GetScheduledJob

func GetScheduledJob(scheduledJobStoreFormat postgres.JobsSchedule) (ScheduledJob, error)

type Scheduler

type Scheduler interface {
	Schedule() http.HandlerFunc
	GetScheduledJobs() http.HandlerFunc
	GetScheduledJob() http.HandlerFunc
	RemoveScheduledJob() http.HandlerFunc
}

func NewScheduler

func NewScheduler(store storage.Store, metadataStore metadata.Store) Scheduler

type Worker

type Worker interface {
	Run(<-chan time.Time, <-chan os.Signal)
}

func NewWorker

func NewWorker(store storage.Store, executioner execution.Executioner, auditor audit.Auditor, mailer mail.Mailer) Worker