Versions in this module Expand all Collapse all v1 v1.0.4 Aug 6, 2026 v1.0.3 Aug 6, 2026 Changes in this version + type CancelJobParams struct + ID string + UpdatedAt pgtype.Timestamptz + type CompleteJobLockedParams struct + CompletedAt pgtype.Timestamptz + ID string + LockedBy pgtype.Text + UpdatedAt pgtype.Timestamptz + type CompleteJobParams struct + CompletedAt pgtype.Timestamptz + ID string + UpdatedAt pgtype.Timestamptz + type DBTX interface + Exec func(context.Context, string, ...interface{}) (pgconn.CommandTag, error) + Query func(context.Context, string, ...interface{}) (pgx.Rows, error) + QueryRow func(context.Context, string, ...interface{}) pgx.Row + type DeleteDeadJobParams struct + DeletedAt pgtype.Timestamptz + ID string + type DeleteJobParams struct + DeletedAt pgtype.Timestamptz + ID string + type InsertJobParams struct + CompletedAt pgtype.Timestamptz + CreatedAt pgtype.Timestamptz + DeletedAt pgtype.Timestamptz + ErrorMessage pgtype.Text + ID string + JobType pgtype.Text + LockedAt pgtype.Timestamptz + LockedBy pgtype.Text + MaxRetries pgtype.Int8 + Payload pgtype.Text + Priority int64 + RetryCount pgtype.Int8 + ScheduledAt pgtype.Timestamptz + Status pgtype.Text + Timeout pgtype.Int8 + UpdatedAt pgtype.Timestamptz + type Job struct + CompletedAt pgtype.Timestamptz + CreatedAt pgtype.Timestamptz + DeletedAt pgtype.Timestamptz + ErrorMessage pgtype.Text + ID string + JobType pgtype.Text + LockedAt pgtype.Timestamptz + LockedBy pgtype.Text + MaxRetries pgtype.Int8 + Payload pgtype.Text + Priority int64 + RetryCount pgtype.Int8 + ScheduledAt pgtype.Timestamptz + Status pgtype.Text + Timeout pgtype.Int8 + UpdatedAt pgtype.Timestamptz + type JobStatusCountsRow struct + Count int64 + Status pgtype.Text + type ListJobsByStatusParams struct + Limit int32 + Offset int32 + Status pgtype.Text + type ListJobsByStatusTypeParams struct + JobType pgtype.Text + Limit int32 + Offset int32 + Status pgtype.Text + type ListJobsByTypeParams struct + JobType pgtype.Text + Limit int32 + Offset int32 + type ListJobsParams struct + Limit int32 + Offset int32 + type MarkJobDeadLockedParams struct + ErrorMessage pgtype.Text + ID string + LockedBy pgtype.Text + UpdatedAt pgtype.Timestamptz + type MarkJobDeadParams struct + ErrorMessage pgtype.Text + ID string + UpdatedAt pgtype.Timestamptz + type MarkJobFailedLockedParams struct + ErrorMessage pgtype.Text + ID string + LockedBy pgtype.Text + RetryCount pgtype.Int8 + ScheduledAt pgtype.Timestamptz + UpdatedAt pgtype.Timestamptz + type MarkJobFailedParams struct + ErrorMessage pgtype.Text + ID string + RetryCount pgtype.Int8 + ScheduledAt pgtype.Timestamptz + UpdatedAt pgtype.Timestamptz + type PurgeJobsByStatusParams struct + DeletedAt pgtype.Timestamptz + Status pgtype.Text + type Queries struct + func New(db DBTX) *Queries + func (q *Queries) CancelJob(ctx context.Context, arg CancelJobParams) (int64, error) + func (q *Queries) CompleteJob(ctx context.Context, arg CompleteJobParams) error + func (q *Queries) CompleteJobLocked(ctx context.Context, arg CompleteJobLockedParams) (int64, error) + func (q *Queries) DeadJobs(ctx context.Context) ([]Job, error) + func (q *Queries) DeleteAllJobs(ctx context.Context) error + func (q *Queries) DeleteDeadJob(ctx context.Context, arg DeleteDeadJobParams) (int64, error) + func (q *Queries) DeleteJob(ctx context.Context, arg DeleteJobParams) (int64, error) + func (q *Queries) GetDeadJob(ctx context.Context, id string) (Job, error) + func (q *Queries) GetJob(ctx context.Context, id string) (Job, error) + func (q *Queries) InsertJob(ctx context.Context, arg InsertJobParams) (Job, error) + func (q *Queries) JobStatusCounts(ctx context.Context) ([]JobStatusCountsRow, error) + func (q *Queries) ListJobs(ctx context.Context, arg ListJobsParams) ([]Job, error) + func (q *Queries) ListJobsByStatus(ctx context.Context, arg ListJobsByStatusParams) ([]Job, error) + func (q *Queries) ListJobsByStatusType(ctx context.Context, arg ListJobsByStatusTypeParams) ([]Job, error) + func (q *Queries) ListJobsByType(ctx context.Context, arg ListJobsByTypeParams) ([]Job, error) + func (q *Queries) MarkJobDead(ctx context.Context, arg MarkJobDeadParams) error + func (q *Queries) MarkJobDeadLocked(ctx context.Context, arg MarkJobDeadLockedParams) (int64, error) + func (q *Queries) MarkJobFailed(ctx context.Context, arg MarkJobFailedParams) error + func (q *Queries) MarkJobFailedLocked(ctx context.Context, arg MarkJobFailedLockedParams) (int64, error) + func (q *Queries) PurgeJobsByStatus(ctx context.Context, arg PurgeJobsByStatusParams) (int64, error) + func (q *Queries) QueryPendingJobs(ctx context.Context) ([]Job, error) + func (q *Queries) ResetJob(ctx context.Context, arg ResetJobParams) (Job, error) + func (q *Queries) ResetStaleJob(ctx context.Context, arg ResetStaleJobParams) error + func (q *Queries) RetryAllDeadJobs(ctx context.Context, updatedAt pgtype.Timestamptz) (int64, error) + func (q *Queries) RetryDeadJob(ctx context.Context, arg RetryDeadJobParams) (Job, error) + func (q *Queries) ScheduledJobs(ctx context.Context, scheduledAt pgtype.Timestamptz) ([]Job, error) + func (q *Queries) SetJobRunning(ctx context.Context, arg SetJobRunningParams) error + func (q *Queries) StaleJobs(ctx context.Context, lockedAt pgtype.Timestamptz) ([]Job, error) + func (q *Queries) WithTx(tx pgx.Tx) *Queries + type ResetJobParams struct + ID string + UpdatedAt pgtype.Timestamptz + type ResetStaleJobParams struct + ID string + UpdatedAt pgtype.Timestamptz + type RetryDeadJobParams struct + ID string + UpdatedAt pgtype.Timestamptz + type SetJobRunningParams struct + ID string + LockedAt pgtype.Timestamptz + LockedBy pgtype.Text + UpdatedAt pgtype.Timestamptz
Go to main page