worker

type BeanstalkdQueue struct {
	Debug io.Writer
	// contains filtered or unexported fields
}

type ExtraInput map[string]string

type Job struct {
	Name   string
	Queuer Queuer

	Description string

	Resource *admin.Resource

	Handle    func(job *QorJob) error
	OnKill    func(job *QorJob) error
	OnStart   func(job *QorJob) error
	OnSuccess func(job *QorJob)
	OnFailed  func(job *QorJob)
	// contains filtered or unexported fields
}

type QorJob struct {
	ID         uint64
	QueueJobId string

	// unit: minute
	// 0 to run job only once
	Interval uint64
	// zero time value to execute job immediately
	StartAt time.Time

	Stopped bool

	Cli        string
	WorkerName string
	JobName    string
	Status     string
	PID        int // TODO: change it into uint

	By string

	RunCounter     uint64
	FailCounter    uint64
	SuccessCounter uint64
	KillCounter    uint64

	ServerHost    string
	ServerUser    string
	ServerSSHPort string

	ExtraValue *ExtraInput `sql:"type:text;"` // Mysql: 64KB
	ExtraFile  *ExtraInput `sql:"type:text;"` // Mysql: 64KB

	UpdatedAt time.Time
	CreatedAt time.Time
	DeletedAt time.Time

	Progress int
	// contains filtered or unexported fields
}

type Queuer interface {
	// Name returns the Queuer's identifier
	Name() string
	// Enqueue pushes a job to a queue, also a Queuer could set a id value (string)
	// in QorJob's QueueJobId if needed
	// Interval
	// StartAt
	Enqueue(job *QorJob) (err error)
	// Purge removes a job from a queue
	Purge(job *QorJob) (err error)
	// Dequeue blocks the process until a job id (and error if any) is returned
	Dequeue() (jobId uint64, err error)
}

type Worker struct {
	Name string

	Jobs map[string]*Job
	// contains filtered or unexported fields
}