jobqueue

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

type Job struct {
	ID         int64  `db:"id"`
	Queue      string `db:"queue"`
	State      string `db:"state"`
	Error      string `db:"error"`
	Payload    string `db:"payload"`
	CreatedOn  int64  `db:"created_on"`
	StartedOn  int64  `db:"started_on"`
	FinishedOn int64  `db:"finished_on"`
}

type JobPayload map[string]interface{}

type JobProcessor interface {
	Process(job *Job) error
}

type JobRepository interface {
	Setup()
	AddJob(job *Job) (*Job, error)
	Process(queue string, interval time.Duration, processors map[string]JobProcessor)
}