jobs

type AutomatedInstanceJobParams struct {
	InstanceID flux.InstanceID
}

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

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

type Handler interface {
	Handle(*Job, JobUpdater) ([]Job, error)
}

type Job struct {
	Instance flux.InstanceID `json:"instanceID"`
	ID       JobID           `json:"id"`

	// To be set when scheduling the job
	Queue       string      `json:"queue"`
	Method      string      `json:"method"`
	Params      interface{} `json:"params"`
	ScheduledAt time.Time   `json:"scheduled_at"`
	Priority    int         `json:"priority"`

	// Key is an optional field, and can be used to create jobs iff a pending
	// job with the same key doesn't exist.
	Key string `json:"key,omitempty"`

	// To be used by the worker
	Submitted time.Time       `json:"submitted"`
	Claimed   time.Time       `json:"claimed,omitempty"`
	Heartbeat time.Time       `json:"heartbeat,omitempty"`
	Finished  time.Time       `json:"finished,omitempty"`
	Log       []string        `json:"log,omitempty"`
	Result    interface{}     `json:"result"` // may be updated to reflect progress
	Status    string          `json:"status"`
	Done      bool            `json:"done"`
	Success   bool            `json:"success"` // only makes sense after done is true
	Error     *flux.BaseError `json:"error,omitempty"`
}

type JobID string

type JobPopper interface {
	NextJob(queues []string) (Job, error)
}

type JobReadPusher interface {
	GetJob(flux.InstanceID, JobID) (Job, error)
	PutJob(flux.InstanceID, Job) (JobID, error)
	PutJobIgnoringDuplicates(flux.InstanceID, Job) (JobID, error)
}

type JobStore interface {
	JobReadPusher
	JobWritePopper
	GC() error
}

type JobUpdater interface {
	UpdateJob(Job) error
	Heartbeat(JobID) error
}

type JobWritePopper interface {
	JobUpdater
	JobPopper
}

type ReleaseJobParams struct {
	flux.ReleaseSpec
	Cause flux.ReleaseCause
}

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