jw

type Job struct {
	ID            string                 `json:"id"`
	Name          string                 `json:"name"`
	Namespace     string                 `json:"namespace"`
	Type          string                 `json:"type"`
	Origin        string                 `json:"origin"`
	Priority      Priority               `json:"priority"`
	Data          map[string]interface{} `json:"data"`
	Private       map[string]interface{} `json:"private"`
	RunAfter      time.Time              `json:"run_after"`
	Retries       int                    `json:"retries"`
	Category      *string                `json:"category"`
	Workflow      *string                `json:"workflow"`
	CreatedAt     time.Time              `json:"created_at"`
	Status        Status                 `json:"status"`
	Attempt       int                    `json:"attempt"`
	Session       int                    `json:"session"`
	Result        *Result                `json:"result"`
	FinishedAt    *time.Time             `json:"finished_at"`
	Weight        int                    `json:"weight"`
	TimeReference time.Time              `json:"time_reference"`
}

type Metrics struct {
	Jobs struct {
		Todo      int
		Pending   int
		Running   int
		Succeeded int
		Failed    int
		Total     int
	}
	Workflows struct {
		Running   int
		Succeeded int
		Failed    int
		Total     int
	}
}

type Model interface {
	CreateJob(job *Job) (*Job, error)
	NextJob(namespace string) (*Job, error)
	UpdateJob(job *Job) (*Job, error)
	NotifyJob(id string, data interface{}) error
	SetJobPriority(id string, priority Priority) error
	SetJobRunAfter(id string, duration time.Duration) error
	CreateWorkflow(wf *Workflow) (*Workflow, error)
	SetWorkflowPriority(id string, priority Priority) error
}

type Priority int

type Result struct {
	Status   Status        `json:"status"`
	NextStep string        `json:"next_step"`
	Value    string        `json:"value"`
	Duration time.Duration `json:"duration"`
	Error    string        `json:"error"`
	Host     string        `json:"host"`
	Worker   string        `json:"worker"`
}

type Runner interface {
	Namespace() string
	Model() Model
	RunJob(job *Job, logger logger.Logger)
}

type Status string

type Step struct {
	Namespace string                 `json:"namespace"`
	Type      string                 `json:"type"`
	Config    map[string]interface{} `json:"config"`
	Retries   int                    `json:"retries"`
	Next      map[string]interface{} `json:"next"`
}

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

type Workflow struct {
	ID          string                 `json:"id"`
	Type        string                 `json:"type"`
	Description string                 `json:"description"`
	Origin      string                 `json:"origin"`
	Priority    Priority               `json:"priority"`
	FirstStep   string                 `json:"first_step"`
	AllSteps    map[string]*Step       `json:"all_steps"`
	Data        map[string]interface{} `json:"data"`
	ExternalID  *string                `json:"external_id"`
	CreatedAt   time.Time              `json:"created_at"`
	Status      Status                 `json:"status"`
	FinishedAt  *time.Time             `json:"finished_at"`
}