storage

type Job struct {
	*job.Job
	Status        string                 `json:"status"`
	Workflow      *string                `json:"workflow"`
	CreatedAt     time.Time              `json:"created_at"`
	FinishedAt    *time.Time             `json:"finished_at"`
	Private       map[string]interface{} `json:"private"`
	Weight        int                    `json:"weight"`
	TimeReference time.Time              `json:"time_reference"`
}

type Storage interface {
	ValidateJob(job *job.Job) error
	InsertJob(job *Job) (bool, error)
	NextJob() (*Job, error)
	UpdateJob(job *Job) error
	ValidateWorkflow(wf *workflow.Workflow) error
	InsertWorkflow(wf *Workflow, job *Job) error
	Workflow(id string, mustExist bool) (*Workflow, error)
	UpdateWorkflow(wf *Workflow) error
}

type Workflow struct {
	*workflow.Workflow
	Status     string     `json:"status"`
	CreatedAt  time.Time  `json:"created_at"`
	FinishedAt *time.Time `json:"finished_at"`
}