Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JobService ¶
type JobService interface {
CreateJob(ctx context.Context, jobConfig *domain.JobConfig, userID string, userAuthToken string) (*domain.Job, error)
GetJob(ctx context.Context, jobNumber int) (*domain.Job, error)
ClaimJob(ctx context.Context) (*domain.Job, error)
UpdateJobState(ctx context.Context, jobNumber int, newState domain.State, userID string) error
GetJobs(ctx context.Context, field sort.SortParameterField, direction sort.SortParameterDirection, states []domain.State, limit, offset int) ([]*domain.Job, int, error)
GetJobTasks(ctx context.Context, states []domain.State, jobNumber int, limit, offset int) ([]*domain.Task, int, error)
CreateTask(ctx context.Context, jobNumber int, task *domain.Task) (*domain.Task, error)
UpdateTask(ctx context.Context, task *domain.Task) error
UpdateTaskState(ctx context.Context, taskID string, newState domain.State) error
ClaimTask(ctx context.Context) (*domain.Task, error)
CountTasksByJobNumber(ctx context.Context, jobNumber int) (int, error)
GetNextJobNumber(ctx context.Context) (*domain.Counter, error)
CreateEvent(ctx context.Context, jobNumber int, event *domain.Event) (*domain.Event, error)
GetJobEvents(ctx context.Context, jobNumber int, limit, offset int) ([]*domain.Event, int, error)
CountEventsByJobNumber(ctx context.Context, jobNumber int) (int, error)
}
JobService defines the contract for job-related operations
func Setup ¶
func Setup(datastore *store.Datastore, appClients *clients.ClientList, cfg *config.Config) JobService
Setup initializes a new JobService with the provided dependencies.
Click to show internal directories.
Click to hide internal directories.