driver

type Iterator interface {
	// Next advances the iterator to the next value, which will then be available through
	// then the Value method. It returns false if no further advancement is possible.
	Next() bool
	// Value returns the current job.
	Value() Job
	// Error returns the current error.
	Error() error
	// Close the iterator
	Close()
}

type Job struct {
	ID      int64  `json:"job_id"`
	Name    string `json:"name"`     // The job name, this is unique.
	Func    string `json:"func"`     // The job function reffer on worker function
	Args    string `json:"workload"` // Job args
	Timeout int64  `json:"timeout"`  // Job processing timeout
	SchedAt int64  `json:"sched_at"` // When to sched the job.
	RunAt   int64  `json:"run_at"`   // The job is start at
	Counter int64  `json:"counter"`  // The job run counter
	Status  string `json:"status"`
}

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

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

type StoreDriver interface {
	// Save job. when job is exists update it, other create one.
	Save(*Job, ...bool) error
	// Delete a job with job id.
	Delete(jobID int64) error
	// Get a job with job id.
	Get(jobID int64) (Job, error)
	// GetOne get a job with func and name.
	GetOne(string, string) (Job, error)
	// NewIterator create a job Iterator with func or nil.
	NewIterator([]byte) Iterator
	// Close the driver
	Close() error
}