Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Executor ¶
type Executor struct {
}
func (*Executor) ExecuteJob ¶
func (executor *Executor) ExecuteJob(info *common.JobExecuteInfo)
execute the once job
type JobLock ¶
type JobLock struct {
// contains filtered or unexported fields
}
func InitJobLock ¶
initialize the lock (TXN)
type JobManager ¶
type JobManager struct {
// contains filtered or unexported fields
}
func (*JobManager) CreateJobLock ¶
func (jobMgr *JobManager) CreateJobLock(jobName string) (jobLock *JobLock)
type LogManager ¶
type LogManager struct {
// contains filtered or unexported fields
}
type Register ¶
type Register struct {
// contains filtered or unexported fields
}
register： /cron/workers/ IP
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
func (*Scheduler) PushJobEvent ¶
push job change event
func (*Scheduler) PushJobResult ¶
func (scheduler *Scheduler) PushJobResult(jobResult *common.JobExecuteResult)
callback job result
func (*Scheduler) TrySchedule ¶
to recalculate the job scheduling
func (*Scheduler) TryStartJob ¶
func (scheduler *Scheduler) TryStartJob(jobPlan *common.JobSchedulePlan)
try start the jobs
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.