quartz

Mar 18, 2024

Changes in this version

type RunOnceTrigger

+ Expired bool

type StdSchedulerOptions

+ RetryInterval time.Duration

Feb 17, 2024

Changes in this version

+ var ErrIllegalState = errors.New("illegal state")

+ var ErrQueueEmpty = errors.New("queue is empty")

+ var ErrTriggerExpired = errors.New("trigger has expired")

type JobDetailOptions

+ Suspended bool

type JobKey

+ func (jobKey *JobKey) Group() string

+ func (jobKey *JobKey) Name() string

type JobQueue

+ Get func(jobKey *JobKey) (ScheduledJob, error)

+ type Matcher interface

+ IsMatch func(T) bool

type Scheduler

+ PauseJob func(jobKey *JobKey) error

+ ResumeJob func(jobKey *JobKey) error

type StdScheduler

+ func (sched *StdScheduler) PauseJob(jobKey *JobKey) error

+ func (sched *StdScheduler) ResumeJob(jobKey *JobKey) error

Jan 17, 2024

Changes in this version

+ const DefaultGroup

+ var ErrCronParse = errors.New("parse cron expression")

+ var ErrIllegalArgument = errors.New("illegal argument")

+ var ErrJobNotFound = errors.New("job not found")

+ var Sep = "::"

+ func ValidateCronExpression(expression string) error

+ type JobDetail struct

+ func NewJobDetail(job Job, jobKey *JobKey) *JobDetail

+ func NewJobDetailWithOptions(job Job, jobKey *JobKey, opts *JobDetailOptions) *JobDetail

+ func (jd *JobDetail) Job() Job

+ func (jd *JobDetail) JobKey() *JobKey

+ func (jd *JobDetail) Options() *JobDetailOptions

+ type JobDetailOptions struct

+ MaxRetries int

+ Replace bool

+ RetryInterval time.Duration

+ func NewDefaultJobDetailOptions() *JobDetailOptions

+ type JobKey struct

+ func NewJobKey(name string) *JobKey

+ func NewJobKeyWithGroup(name, group string) *JobKey

+ func (jobKey *JobKey) Equals(that *JobKey) bool

+ func (jobKey *JobKey) String() string

+ type JobQueue interface

+ Clear func() error

+ Head func() (ScheduledJob, error)

+ Pop func() (ScheduledJob, error)

+ Push func(job ScheduledJob) error

+ Remove func(jobKey *JobKey) (ScheduledJob, error)

+ ScheduledJobs func() []ScheduledJob

+ Size func() int

type ScheduledJob

+ JobDetail func() *JobDetail

+ Trigger func() Trigger

Nov 10, 2023

Changes in this version

type CurlJob

+ func NewCurlJobWithOptions(request *http.Request, opts CurlJobOptions) *CurlJob

+ func (cu *CurlJob) DumpResponse(body bool) ([]byte, error)

+ type CurlJobOptions struct

+ Callback func(context.Context, *CurlJob)

+ HTTPClient HTTPHandler

type ShellJob

+ func NewShellJobWithCallback(cmd string, f func(context.Context, *ShellJob)) *ShellJob

Oct 10, 2023

Changes in this version

type CurlJob

+ func NewCurlJobWithHTTPClient(request *http.Request, httpClient HTTPHandler) (*CurlJob, error)

+ type HTTPHandler interface

+ Do func(req *http.Request) (*http.Response, error)

type ShellJob

+ ExitCode int

+ Stderr string

+ Stdout string

type StdSchedulerOptions

+ OutdatedThreshold time.Duration

Jan 10, 2023

Changes in this version

type Job

+ func NewIsolatedJob(underlying Job) Job

type Scheduler

+ Wait func(context.Context)

type StdScheduler

+ func NewStdSchedulerWithOptions(opts StdSchedulerOptions) *StdScheduler

+ func (sched *StdScheduler) Wait(ctx context.Context)

+ type StdSchedulerOptions struct

+ BlockingExecution bool

+ WorkerLimit int

Nov 19, 2022

Changes in this version

+ type Function func() (R, error)

+ type FunctionJob struct

+ Error error

+ JobStatus JobStatus

+ Result *R

+ func NewFunctionJob(function Function[R]) *FunctionJob[R]

+ func NewFunctionJobWithDesc(desc string, function Function[R]) *FunctionJob[R]

+ func (f *FunctionJob[R]) Description() string

+ func (f *FunctionJob[R]) Execute()

+ func (f *FunctionJob[R]) Key() int

May 24, 2022

Changes in this version

type CronTrigger

+ func NewCronTriggerWithLoc(expr string, location *time.Location) (*CronTrigger, error)

Sep 25, 2021

Changes in this version

type Scheduler

+ IsStarted func() bool

type StdScheduler

+ func (sched *StdScheduler) IsStarted() bool

Nov 28, 2020

Changes in this version

type PriorityQueue

+ func (pq *PriorityQueue) Remove(i int) interface{}

Jul 12, 2020

Changes in this version

type CronField

+ func (cf *CronField) String() string

type CurlJob

+ URL string

Apr 22, 2019

Changes in this version

+ type CurlJob struct

+ Body string

+ Headers map[string]string

+ JobStatus JobStatus

+ RequestMethod string

+ Response string

+ StatusCode int

+ Url string

+ func NewCurlJob(method string, url string, body string, headers map[string]string) (*CurlJob, error)

+ func (cu *CurlJob) Description() string

+ func (cu *CurlJob) Execute()

+ func (cu *CurlJob) Key() int

+ type JobStatus int8

+ const FAILURE

+ const NA

+ const OK

+ type ShellJob struct

+ Cmd string

+ JobStatus JobStatus

+ Result string

+ func NewShellJob(cmd string) *ShellJob

+ func (sh *ShellJob) Description() string

+ func (sh *ShellJob) Execute()

+ func (sh *ShellJob) Key() int

Apr 19, 2019

Changes in this version

+ func HashCode(s string) int

+ func NowNano() int64

+ type CronExpressionParser struct

+ func NewCronExpressionParser(lastDefined int) *CronExpressionParser

+ type CronField struct

+ type CronTrigger struct

+ func NewCronTrigger(expr string) (*CronTrigger, error)

+ func (ct *CronTrigger) NextFireTime(prev int64) (int64, error)

+ func (st *CronTrigger) Description() string

+ type Item struct

+ Job Job

+ Trigger Trigger

+ type Job interface

+ Description func() string

+ Execute func()

+ Key func() int

+ type PriorityQueue []*Item

+ func (pq *PriorityQueue) Head() *Item

+ func (pq *PriorityQueue) Pop() interface{}

+ func (pq *PriorityQueue) Push(x interface{})

+ func (pq *PriorityQueue) Update(item *Item, nextRunTime int64)

+ func (pq PriorityQueue) Len() int

+ func (pq PriorityQueue) Less(i, j int) bool

+ func (pq PriorityQueue) Swap(i, j int)

+ type RunOnceTrigger struct

+ Delay time.Duration

+ func NewRunOnceTrigger(delay time.Duration) *RunOnceTrigger

+ func (st *RunOnceTrigger) Description() string

+ func (st *RunOnceTrigger) NextFireTime(prev int64) (int64, error)

+ type ScheduledJob struct

+ Job Job

+ NextRunTime int64

+ TriggerDescription string

+ type Scheduler interface

+ Clear func()

+ DeleteJob func(key int) error

+ GetJobKeys func() []int

+ GetScheduledJob func(key int) (*ScheduledJob, error)

+ ScheduleJob func(job Job, trigger Trigger) error

+ Start func()

+ Stop func()

+ type SimpleTrigger struct

+ Interval time.Duration

+ func NewSimpleTrigger(interval time.Duration) *SimpleTrigger

+ func (st *SimpleTrigger) Description() string

+ func (st *SimpleTrigger) NextFireTime(prev int64) (int64, error)

+ type StdScheduler struct

+ Queue *PriorityQueue

+ func NewStdScheduler() *StdScheduler

+ func (sched *StdScheduler) Clear()

+ func (sched *StdScheduler) DeleteJob(key int) error

+ func (sched *StdScheduler) GetJobKeys() []int

+ func (sched *StdScheduler) GetScheduledJob(key int) (*ScheduledJob, error)

+ func (sched *StdScheduler) ScheduleJob(job Job, trigger Trigger) error

+ func (sched *StdScheduler) Start()

+ func (sched *StdScheduler) Stop()

+ type Trigger interface

+ Description func() string

+ NextFireTime func(prev int64) (int64, error)