Documentation
¶
Overview ¶
Package job provides job queue API handlers.
Index ¶
- func Handler(logger *slog.Logger, jobClient client.JobClient, signingKey string, ...) []func(e *echo.Echo)
- type Job
- func (j *Job) DeleteJobByID(ctx context.Context, request gen.DeleteJobByIDRequestObject) (gen.DeleteJobByIDResponseObject, error)
- func (j *Job) GetJobByID(ctx context.Context, request gen.GetJobByIDRequestObject) (gen.GetJobByIDResponseObject, error)
- func (j *Job) GetJobs(ctx context.Context, request gen.GetJobsRequestObject) (gen.GetJobsResponseObject, error)
- func (j *Job) RetryJobByID(ctx context.Context, request gen.RetryJobByIDRequestObject) (gen.RetryJobByIDResponseObject, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Job ¶
type Job struct {
// JobClient provides job queue operations.
JobClient client.JobClient
// contains filtered or unexported fields
}
Job implementation of the Job APIs operations.
func (*Job) DeleteJobByID ¶
func (j *Job) DeleteJobByID( ctx context.Context, request gen.DeleteJobByIDRequestObject, ) (gen.DeleteJobByIDResponseObject, error)
DeleteJobByID deletes a specific job by its ID.
func (*Job) GetJobByID ¶
func (j *Job) GetJobByID( ctx context.Context, request gen.GetJobByIDRequestObject, ) (gen.GetJobByIDResponseObject, error)
GetJobByID retrieves details of a specific job by its ID.
func (*Job) GetJobs ¶
func (j *Job) GetJobs( ctx context.Context, request gen.GetJobsRequestObject, ) (gen.GetJobsResponseObject, error)
GetJobs lists jobs, optionally filtered by status.
func (*Job) RetryJobByID ¶
func (j *Job) RetryJobByID( ctx context.Context, request gen.RetryJobByIDRequestObject, ) (gen.RetryJobByIDResponseObject, error)
RetryJobByID creates a new job using the same operation data as an existing job.
Source Files
¶
Click to show internal directories.
Click to hide internal directories.