scheduler

Documentation

Index

• func DefaultStatusChangeCallback(task ScheduledTask, status Status)
• type Factory
• type ScheduledTask
• type Scheduler
• type Status
  • func WaitForScheduledTask(t ScheduledTask, callback StatusChangeCallback) (Status, error)
• type StatusChangeCallback

Functions

func DefaultStatusChangeCallback

func DefaultStatusChangeCallback(task ScheduledTask, status Status)

Types

type Factory

type Factory interface {
	Create(provider string, options map[string]interface{}) (Scheduler, error)
}

type ScheduledTask

type ScheduledTask interface {
	Status() (Status, error)
	Subject() interface{}
}

type Scheduler

type Scheduler interface {
	ScheduleCompilation(f compilationdatastore.FilterParams) (ScheduledTask, error)
	ScheduleAnalysis(ref analysis.Reference) (ScheduledTask, error)
}

multiple schedulings of the same thing should not cause duplicates

type Status

type Status string

var (
	StatusUnknown   Status = "unknown"
	StatusPending   Status = "pending"
	StatusFailed    Status = "failed"
	StatusRunning   Status = "running"
	StatusFinishing Status = "finishing"
	StatusSucceeded Status = "finished"
)

func WaitForScheduledTask

func WaitForScheduledTask(t ScheduledTask, callback StatusChangeCallback) (Status, error)

type StatusChangeCallback

type StatusChangeCallback func(ScheduledTask, Status) // TODO pass only ScheduledTask.Subject()?