worker

Documentation

Index

• func InitExecutor() (err error)
• func InitJobMgr() (err error)
• func InitLogSink() (err error)
• func InitRegister() (err error)
• func InitScheduler() (err error)
• type Executor
  • func (executor *Executor) ExecuteJob(info *common.JobExecuteInfo)
• type JobLock
  • func InitJobLock(jobName string, kv clientv3.KV, lease clientv3.Lease) (jobLock *JobLock)
  • func (jobLock *JobLock) TryLock() (err error)
  • func (jobLock *JobLock) Unlock()
• type JobManager
  • func (jobMgr *JobManager) CreateJobLock(jobName string) (jobLock *JobLock)
• type LogManager
  • func (logSink *LogManager) Append(jobLog *common.JobLog)
• type Register
• type Scheduler
  • func (scheduler *Scheduler) PushJobEvent(jobEvent *common.JobEvent)
  • func (scheduler *Scheduler) PushJobResult(jobResult *common.JobExecuteResult)
  • func (scheduler *Scheduler) TrySchedule() (scheduleAfter time.Duration)
  • func (scheduler *Scheduler) TryStartJob(jobPlan *common.JobSchedulePlan)

Functions

func InitExecutor

func InitExecutor() (err error)

initialize the job executor

func InitJobMgr

func InitJobMgr() (err error)

initialize the job manager

func InitLogSink

func InitLogSink() (err error)

initialize the InitLogSink

func InitRegister

func InitRegister() (err error)

initialize the InitRegister

func InitScheduler

func InitScheduler() (err error)

initialize the InitScheduler

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

func InitJobLock(jobName string, kv clientv3.KV, lease clientv3.Lease) (jobLock *JobLock)

initialize the lock (TXN)

func (*JobLock) TryLock

func (jobLock *JobLock) TryLock() (err error)

func (*JobLock) Unlock

func (jobLock *JobLock) Unlock()

The release of the lock

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
}

func (*LogManager) Append

func (logSink *LogManager) Append(jobLog *common.JobLog)

send logger

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

func (scheduler *Scheduler) PushJobEvent(jobEvent *common.JobEvent)

push job change event

func (*Scheduler) PushJobResult

func (scheduler *Scheduler) PushJobResult(jobResult *common.JobExecuteResult)

callback job result

func (*Scheduler) TrySchedule

func (scheduler *Scheduler) TrySchedule() (scheduleAfter time.Duration)

to recalculate the job scheduling

func (*Scheduler) TryStartJob

func (scheduler *Scheduler) TryStartJob(jobPlan *common.JobSchedulePlan)

try start the jobs