litejob

type Dispatch struct {
	sync.Mutex

	Count uint32
	// contains filtered or unexported fields
}

type DispatchConfigure struct {
	Engine          string               // storage engine name.eg:(redis,sqlite,memory)
	MaxConcurrency  uint32               // max concurrency goroutine
	MaxReplyCount   uint32               // max reply job to job list when job ask need again
	HeartInterval   time.Duration        // sleep some time when empty job list
	DumpInterval    time.Duration        // not used
	Logfile         string               // log file path
	EngineConfigure EngineConfigure      // engine configure
	Callback        JobCallbackConfigure // job callbacks
}

type DispatchStatus struct {
	Running uint32 //runing goroutine count
	Len     uint32 //job list length
}

type EngineConfigure map[string]interface{}

type Job struct {
	Id         string      //任务id,使用/dev/urandom 获取
	Name       string      //任务名称,调度器注册的任务名称
	Param      interface{} //任务参数
	CreateTime time.Time   //任务创建时间
	FlushTime  time.Time   //任务结束时间
	Status     JobStatus   //任务状态
	ReplyCount uint32      //重试次数
}

type JobCallback func(job *Job)

type JobCallbackConfigure struct {
	After  JobCallback
	Before JobCallback
}

type JobHandler func(job *Job) JobReturn

type JobReturn struct {
	Status JobStatus //任务状态
	Msg    string    //任务执行结果
}

type JobState struct {
	JobId      string
	Name       string
	Status     string
	Msg        string
	RunTime    int
	WaitTime   int
	ReplyCount int
}

type JobStatus uint

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

type Storage interface {
	JobPush(job *Job) error
	JobPop() (*Job, error)
	JobFlush() error
	JobLen() uint32
	JobStateUpdate(state *JobState) error
	JobState(jobId string) (*JobState, error)
}

type StorageInitFunc func(configure *DispatchConfigure) Storage