postgres

package

v0.1.0 Latest Latest Go to latest Published: May 17, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Details

View Source

const DefaultTableName = "agentflow_jobs"

This section is empty.

This section is empty.

type Option func(*Queue) error

func WithTableName(name string) Option

type Queue struct {
	// contains filtered or unexported fields
}

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)