Versions in this module Expand all Collapse all v0 v0.1.0 Jan 19, 2026 Changes in this version + 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 GoqueueJob struct + Arguments []byte + CreatedAt pgtype.Timestamp + Error pgtype.Text + FinishedAt pgtype.Timestamp + JobID int32 + MaxRetries int32 + Metadata []byte + QueueName string + RetryAttempt int32 + RetryPolicy GoqueueRetryPolicy + ScheduledAt pgtype.Timestamp + StartedAt pgtype.Timestamp + Status GoqueueJobStatus + type GoqueueJobStatus string + const GoqueueJobStatusAvailable + const GoqueueJobStatusFailed + const GoqueueJobStatusFinished + const GoqueueJobStatusRunning + func (e *GoqueueJobStatus) Scan(src interface{}) error + type GoqueueQueue struct + CreatedAt pgtype.Timestamp + IsFifo bool + QueueName string + type GoqueueRetryPolicy string + const GoqueueRetryPolicyConstant + const GoqueueRetryPolicyExponential + const GoqueueRetryPolicyLinear + func (e *GoqueueRetryPolicy) Scan(src interface{}) error + type InsertJobParams struct + Arguments []byte + MaxRetries int32 + Metadata []byte + QueueName string + RetryPolicy GoqueueRetryPolicy + ScheduledAt pgtype.Timestamp + type InsertQueueParams struct + IsFifo bool + QueueName string + type MoveJobToDLQParams struct + JobID int32 + QueueName string + type NullGoqueueJobStatus struct + GoqueueJobStatus GoqueueJobStatus + Valid bool + func (ns *NullGoqueueJobStatus) Scan(value interface{}) error + func (ns NullGoqueueJobStatus) Value() (driver.Value, error) + type NullGoqueueRetryPolicy struct + GoqueueRetryPolicy GoqueueRetryPolicy + Valid bool + func (ns *NullGoqueueRetryPolicy) Scan(value interface{}) error + func (ns NullGoqueueRetryPolicy) Value() (driver.Value, error) + type Querier interface + FetchJob func(ctx context.Context, queueName string) (GoqueueJob, error) + FetchJobLocked func(ctx context.Context, queueName string) (GoqueueJob, error) + GetQueue func(ctx context.Context, queueName string) (GoqueueQueue, error) + InsertJob func(ctx context.Context, arg InsertJobParams) (GoqueueJob, error) + InsertQueue func(ctx context.Context, arg InsertQueueParams) (GoqueueQueue, error) + LockQueue func(ctx context.Context, hashtext string) (bool, error) + MoveJobToDLQ func(ctx context.Context, arg MoveJobToDLQParams) (GoqueueJob, error) + RescheduleJob func(ctx context.Context, arg RescheduleJobParams) (GoqueueJob, error) + UpdateJob func(ctx context.Context, arg UpdateJobParams) (GoqueueJob, error) + UpdateJobFailed func(ctx context.Context, arg UpdateJobFailedParams) (GoqueueJob, error) + UpdateJobFinished func(ctx context.Context, jobID int32) (GoqueueJob, error) + UpdateJobStatus func(ctx context.Context, arg UpdateJobStatusParams) (GoqueueJob, error) + type Queries struct + func New(db DBTX) *Queries + func (q *Queries) FetchJob(ctx context.Context, queueName string) (GoqueueJob, error) + func (q *Queries) FetchJobLocked(ctx context.Context, queueName string) (GoqueueJob, error) + func (q *Queries) GetQueue(ctx context.Context, queueName string) (GoqueueQueue, error) + func (q *Queries) InsertJob(ctx context.Context, arg InsertJobParams) (GoqueueJob, error) + func (q *Queries) InsertQueue(ctx context.Context, arg InsertQueueParams) (GoqueueQueue, error) + func (q *Queries) LockQueue(ctx context.Context, hashtext string) (bool, error) + func (q *Queries) MoveJobToDLQ(ctx context.Context, arg MoveJobToDLQParams) (GoqueueJob, error) + func (q *Queries) RescheduleJob(ctx context.Context, arg RescheduleJobParams) (GoqueueJob, error) + func (q *Queries) UpdateJob(ctx context.Context, arg UpdateJobParams) (GoqueueJob, error) + func (q *Queries) UpdateJobFailed(ctx context.Context, arg UpdateJobFailedParams) (GoqueueJob, error) + func (q *Queries) UpdateJobFinished(ctx context.Context, jobID int32) (GoqueueJob, error) + func (q *Queries) UpdateJobStatus(ctx context.Context, arg UpdateJobStatusParams) (GoqueueJob, error) + func (q *Queries) WithTx(tx pgx.Tx) *Queries + type RescheduleJobParams struct + JobID int32 + ScheduledAt pgtype.Timestamp + type UpdateJobFailedParams struct + Error pgtype.Text + JobID int32 + type UpdateJobParams struct + Arguments []byte + CreatedAt pgtype.Timestamp + Error pgtype.Text + FinishedAt pgtype.Timestamp + JobID int32 + Status GoqueueJobStatus + type UpdateJobStatusParams struct + JobID int32 + Status GoqueueJobStatus
Go to main page