application

type JobService interface {
	CreateJob(ctx context.Context, jobConfig *domain.JobConfig) (*domain.Job, error)
	GetJob(ctx context.Context, jobID string) (*domain.Job, error)
	ClaimJob(ctx context.Context) (*domain.Job, error)
	UpdateJobState(ctx context.Context, jobID string, newState domain.JobState) error
	GetJobs(ctx context.Context, states []domain.JobState, limit, offset int) ([]*domain.Job, int, error)
	GetJobTasks(ctx context.Context, jobID string, limit, offset int) ([]*domain.Task, int, error)
	CreateTask(ctx context.Context, jobID string, task *domain.Task) (*domain.Task, error)
	UpdateTask(ctx context.Context, task *domain.Task) error
	UpdateTaskState(ctx context.Context, taskID string, newState domain.TaskState) error
	ClaimTask(ctx context.Context) (*domain.Task, error)
	CountTasksByJobID(ctx context.Context, jobID string) (int, error)
	CreateEvent(ctx context.Context, jobID string, event *domain.Event) (*domain.Event, error)
	GetJobEvents(ctx context.Context, jobID string, limit, offset int) ([]*domain.Event, int, error)
	CountEventsByJobID(ctx context.Context, jobID string) (int, error)
}