inmem

package

v0.2.2 Latest Latest Go to latest Published: May 23, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewQueue() *Queue

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

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

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

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

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

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

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

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

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