Versions in this module Expand all Collapse all v0 v0.1.0 Oct 20, 2026 Changes in this version + var ErrBatchAlreadyClosed = errors.New("batch already closed") + type AdvanceScheduleParams struct + ID uuid.UUID + LastRun time.Time + NextRun time.Time + type ClaimJobsOldestParams struct + BatchLimit int32 + Owner string + QueueName string + Ttl pgtype.Interval + type ClaimJobsParams struct + BatchLimit int32 + Owner string + QueueName string + Ttl pgtype.Interval + type CompleteJobParams struct + ID uuid.UUID + Owner string + Token int64 + type DBTX interface + CopyFrom func(ctx context.Context, tableName pgx.Identifier, columnNames []string, ...) (int64, error) + 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 + SendBatch func(context.Context, *pgx.Batch) pgx.BatchResults + type DueSchedulesParams struct + BatchLimit int32 + Now time.Time + type FailJobParams struct + Cause *string + ID uuid.UUID + Owner string + Permanent bool + RetryAt time.Time + Token int64 + type GetJobByIdemParams struct + IdempotencyKey string + Queue string + type HeartbeatLeasesParams struct + Ids []uuid.UUID + Owner string + Tokens []int64 + Until time.Time + type HeartbeatLeasesRow struct + CancelRequested bool + ID uuid.UUID + LeaseToken int64 + type InsertJobEventParams struct + At *time.Time + Attempt int32 + Error *string + FromStatus string + JobID uuid.UUID + Queue string + ToStatus string + Type string + type InsertJobEventsBatchBatchResults struct + func (b *InsertJobEventsBatchBatchResults) Close() error + func (b *InsertJobEventsBatchBatchResults) Exec(f func(int, error)) + type InsertJobEventsBatchParams struct + At *time.Time + Attempt int32 + Error *string + FromStatus string + JobID uuid.UUID + Queue string + ToStatus string + Type string + type InsertJobParams struct + Backoff []byte + Delay pgtype.Interval + ID uuid.UUID + IdempotencyKey *string + MaxAttempts int32 + Payload []byte + Priority int16 + Queue string + RunAt *time.Time + Traceparent *string + Type string + type InsertJobsCopyParams struct + Backoff []byte + ID uuid.UUID + IdempotencyKey *string + MaxAttempts int32 + Payload []byte + Priority int16 + Queue string + RunAt time.Time + Traceparent *string + Type string + type InsertProcessedEffectParams struct + JobID uuid.UUID + Key string + Scope string + type InsertScheduleParams struct + Backoff []byte + Cron string + Enabled bool + ID uuid.UUID + JobType string + MaxAttempts int32 + Name string + NextRun time.Time + Payload []byte + Priority int16 + Queue string + Timezone string + type Job struct + Attempts int32 + Backoff []byte + CancelRequested bool + CreatedAt time.Time + FinishedAt *time.Time + ID uuid.UUID + IdempotencyKey *string + LastError *string + LeaseOwner *string + LeaseToken int64 + LeaseUntil *time.Time + MaxAttempts int32 + Payload []byte + Priority int16 + Queue string + RunAt time.Time + StartedAt *time.Time + Status JobStatus + Traceparent *string + Type string + UpdatedAt time.Time + type JobEvent struct + At time.Time + Attempt int32 + Error *string + FromStatus *JobStatus + ID int64 + JobID uuid.UUID + Queue string + ToStatus JobStatus + Type string + type JobStatus string + const JobStatusCancelled + const JobStatusDead + const JobStatusFailed + const JobStatusLeased + const JobStatusQueued + const JobStatusSucceeded + func (e *JobStatus) Scan(src interface{}) error + type ListJobsParams struct + AfterCreatedAt *time.Time + AfterID uuid.NullUUID + PageLimit int32 + Queue *string + Status *JobStatus + Type *string + type ListSchedulesParams struct + AfterName string + PageLimit int32 + type NotifyReadyParams struct + Channel string + Queue string + type NullJobStatus struct + JobStatus JobStatus + Valid bool + func (ns *NullJobStatus) Scan(value interface{}) error + func (ns NullJobStatus) Value() (driver.Value, error) + type ProcessedEffect struct + JobID uuid.UUID + Key string + ProcessedAt time.Time + Scope string + type ProcessedEffectExistsParams struct + Key string + Scope string + type PurgeJobsParams struct + BatchLimit int32 + OlderThan pgtype.Interval + Queue *string + Statuses []string + type Queries struct + func New(db DBTX) *Queries + func (q *Queries) AdvanceSchedule(ctx context.Context, arg AdvanceScheduleParams) (int64, error) + func (q *Queries) CancelQueuedJob(ctx context.Context, id uuid.UUID) (Job, error) + func (q *Queries) ClaimJobs(ctx context.Context, arg ClaimJobsParams) ([]Job, error) + func (q *Queries) ClaimJobsOldest(ctx context.Context, arg ClaimJobsOldestParams) ([]Job, error) + func (q *Queries) CompleteJob(ctx context.Context, arg CompleteJobParams) (Job, error) + func (q *Queries) DBNow(ctx context.Context) (time.Time, error) + func (q *Queries) DeleteSchedule(ctx context.Context, id uuid.UUID) (int64, error) + func (q *Queries) DueSchedules(ctx context.Context, arg DueSchedulesParams) ([]Schedule, error) + func (q *Queries) FailJob(ctx context.Context, arg FailJobParams) (Job, error) + func (q *Queries) GetJob(ctx context.Context, id uuid.UUID) (Job, error) + func (q *Queries) GetJobByIdem(ctx context.Context, arg GetJobByIdemParams) (Job, error) + func (q *Queries) GetJobForUpdate(ctx context.Context, id uuid.UUID) (Job, error) + func (q *Queries) GetSchedule(ctx context.Context, id uuid.UUID) (Schedule, error) + func (q *Queries) HeartbeatLeases(ctx context.Context, arg HeartbeatLeasesParams) ([]HeartbeatLeasesRow, error) + func (q *Queries) InsertJob(ctx context.Context, arg InsertJobParams) (Job, error) + func (q *Queries) InsertJobEvent(ctx context.Context, arg InsertJobEventParams) error + func (q *Queries) InsertJobEventsBatch(ctx context.Context, arg []InsertJobEventsBatchParams) *InsertJobEventsBatchBatchResults + func (q *Queries) InsertJobsCopy(ctx context.Context, arg []InsertJobsCopyParams) (int64, error) + func (q *Queries) InsertProcessedEffect(ctx context.Context, arg InsertProcessedEffectParams) (int64, error) + func (q *Queries) InsertSchedule(ctx context.Context, arg InsertScheduleParams) (Schedule, error) + func (q *Queries) ListJobEvents(ctx context.Context, jobID uuid.UUID) ([]JobEvent, error) + func (q *Queries) ListJobs(ctx context.Context, arg ListJobsParams) ([]Job, error) + func (q *Queries) ListSchedules(ctx context.Context, arg ListSchedulesParams) ([]Schedule, error) + func (q *Queries) NotifyReady(ctx context.Context, arg NotifyReadyParams) error + func (q *Queries) ProcessedEffectExists(ctx context.Context, arg ProcessedEffectExistsParams) (bool, error) + func (q *Queries) PruneJobEvents(ctx context.Context, olderThan pgtype.Interval) (int64, error) + func (q *Queries) PurgeJobs(ctx context.Context, arg PurgeJobsParams) (int64, error) + func (q *Queries) QueueDepth(ctx context.Context) ([]QueueDepthRow, error) + func (q *Queries) RequestCancel(ctx context.Context, id uuid.UUID) (Job, error) + func (q *Queries) RequeueExpiredJob(ctx context.Context, arg []RequeueExpiredJobParams) *RequeueExpiredJobBatchResults + func (q *Queries) RetryJob(ctx context.Context, id uuid.UUID) (Job, error) + func (q *Queries) SelectExpiredLeases(ctx context.Context, arg SelectExpiredLeasesParams) ([]SelectExpiredLeasesRow, error) + func (q *Queries) UpdateSchedule(ctx context.Context, arg UpdateScheduleParams) (Schedule, error) + func (q *Queries) WithTx(tx pgx.Tx) *Queries + type QueueDepthRow struct + N int64 + OldestRunAt time.Time + Queue string + Status JobStatus + type RequeueExpiredJobBatchResults struct + func (b *RequeueExpiredJobBatchResults) Close() error + func (b *RequeueExpiredJobBatchResults) Exec(f func(int, error)) + type RequeueExpiredJobParams struct + Cause string + ID uuid.UUID + RunAt time.Time + Status string + type Schedule struct + Backoff []byte + CreatedAt time.Time + Cron string + Enabled bool + ID uuid.UUID + JobType string + LastRun *time.Time + MaxAttempts int32 + Name string + NextRun time.Time + Payload []byte + Priority int16 + Queue string + Timezone string + UpdatedAt time.Time + type SelectExpiredLeasesParams struct + BatchLimit int32 + Now time.Time + type SelectExpiredLeasesRow struct + Attempts int32 + Backoff []byte + CancelRequested bool + ID uuid.UUID + MaxAttempts int32 + Queue string + Type string + type UpdateScheduleParams struct + Backoff []byte + Cron string + Enabled bool + ID uuid.UUID + JobType string + MaxAttempts int32 + NextRun time.Time + Payload []byte + Priority int16 + Queue string + Timezone string
Go to main page