job

type ClaimOptions struct {
	JobID string
	Names []string
}

type JobStatus string

type Reporter interface {
	GetCountByNameByStatus(ctx context.Context) (map[string]map[JobStatus]int64, error)
}

type Repository interface {
	// crud
	Get(ctx context.Context, id string) (*goqmodel.Job, error)
	List(ctx context.Context, args *goqmodel.ListJobsQueryParams) (*goqmodel.ListJobsResponse, error)
	Search(ctx context.Context, args *goqmodel.SearchJobsRequest) (*goqmodel.SearchJobsResponse, error)
	Delete(ctx context.Context, id string) error
	// job queue semantics
	Queue(ctx context.Context, j *goqmodel.Job) (*goqmodel.Job, error)
	Claim(ctx context.Context, opts *ClaimOptions) (*goqmodel.Job, error)
	Release(ctx context.Context, id string) (*goqmodel.Job, error)
	Success(ctx context.Context, id string, output goqmodel.JSONObject) (*goqmodel.Job, error)
	Error(ctx context.Context, id string, output goqmodel.JSONObject) (*goqmodel.Job, error)
}