postgres

Jul 24, 2026

Changes in this version

type Queue

+ func (q *Queue) Release(ctx context.Context, lease asyncpkg.Lease) error

Jul 23, 2026

Changes in this version

type Queue

+ func (q *Queue) Pause(ctx context.Context, lease asyncpkg.Lease, result asyncpkg.PauseResult) error

May 21, 2026

Changes in this version

type Queue

+ func (q *Queue) ListJobs(ctx context.Context, filter asyncpkg.JobFilter) ([]asyncpkg.Job, error)

+ func (q *Queue) Requeue(ctx context.Context, jobID string) error

May 17, 2026

Changes in this version

+ const DefaultTableName

+ type Option func(*Queue) error

+ func WithTableName(name string) Option

+ type Queue struct

+ func NewQueue(db *sql.DB, opts ...Option) (*Queue, error)

+ func (q *Queue) Cancel(ctx context.Context, jobID string) error

+ func (q *Queue) Complete(ctx context.Context, lease asyncpkg.Lease) error

+ func (q *Queue) Enqueue(ctx context.Context, job asyncpkg.Job) (asyncpkg.Job, error)

+ func (q *Queue) Fail(ctx context.Context, lease asyncpkg.Lease, cause error) error

+ func (q *Queue) Lease(ctx context.Context, workerID string, ttl time.Duration) (asyncpkg.Lease, bool, error)

+ func (q *Queue) Load(ctx context.Context, jobID string) (asyncpkg.Job, error)

+ func (q *Queue) Renew(ctx context.Context, lease asyncpkg.Lease, ttl time.Duration) (asyncpkg.Lease, bool, error)