quartz

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

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

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

type CurlJob struct {
	RequestMethod string
	Url           string
	Body          string
	Headers       map[string]string
	Response      string
	StatusCode    int
	JobStatus     JobStatus
	// contains filtered or unexported fields
}

type Item struct {
	Job     Job
	Trigger Trigger
	// contains filtered or unexported fields
}

type Job interface {
	Execute()
	Description() string
	Key() int
}

type JobStatus int8

type PriorityQueue []*Item

type RunOnceTrigger struct {
	Delay time.Duration
	// contains filtered or unexported fields
}

type ScheduledJob struct {
	Job                Job
	TriggerDescription string
	NextRunTime        int64
}

type Scheduler interface {
	//start scheduler
	Start()
	//schedule Job with given Trigger
	ScheduleJob(job Job, trigger Trigger) error
	//get all scheduled Job keys
	GetJobKeys() []int
	//get scheduled Job metadata
	GetScheduledJob(key int) (*ScheduledJob, error)
	//remove Job from execution queue
	DeleteJob(key int) error
	//clear all scheduled jobs
	Clear()
	//shutdown scheduler
	Stop()
}

type ShellJob struct {
	Cmd       string
	Result    string
	JobStatus JobStatus
}

type SimpleTrigger struct {
	Interval time.Duration
}

type StdScheduler struct {
	sync.Mutex
	Queue *PriorityQueue
	// contains filtered or unexported fields
}

type Trigger interface {
	NextFireTime(prev int64) (int64, error)
	Description() string
}