pgq

package module

v4.0.0-beta.4 Latest Latest Go to latest Published: May 10, 2023 License: BSD-2-Clause Imports: 11 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/vmihailenco/taskq

Documentation ¶

Index ¶

func NewFactory(db *bun.DB) taskq.Factory
type Job
type Queue
- func NewQueue(db *bun.DB, opt *taskq.QueueConfig) *Queue

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewFactory ¶

func NewFactory(db *bun.DB) taskq.Factory

Types ¶

type Job ¶

type Job struct {
	bun.BaseModel `bun:"taskq_jobs,alias:m"`

	ID            ulid.ULID `bun:"type:uuid"`
	Queue         string
	RunAt         time.Time
	ReservedCount int
	ReservedAt    time.Time
	Data          []byte
}

type Queue ¶

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

func NewQueue ¶

func NewQueue(db *bun.DB, opt *taskq.QueueConfig) *Queue

func (*Queue) AddJob ¶

func (q *Queue) AddJob(ctx context.Context, job *taskq.Job) error

func (*Queue) Close ¶

func (q *Queue) Close() error

Close is like CloseTimeout with 30 seconds timeout.

func (*Queue) CloseTimeout ¶

func (q *Queue) CloseTimeout(timeout time.Duration) error

CloseTimeout closes the queue waiting for pending messages to be processed.

func (*Queue) Consumer ¶

func (q *Queue) Consumer() taskq.QueueConsumer

func (*Queue) Delete ¶

func (q *Queue) Delete(ctx context.Context, job *taskq.Job) error

func (*Queue) Len ¶

func (q *Queue) Len(ctx context.Context) (int, error)

func (*Queue) Name ¶

func (q *Queue) Name() string

func (*Queue) Options ¶

func (q *Queue) Options() *taskq.QueueConfig

func (*Queue) Purge ¶

func (q *Queue) Purge(ctx context.Context) error

func (*Queue) Release ¶

func (q *Queue) Release(ctx context.Context, job *taskq.Job) error

func (*Queue) ReserveN ¶

func (q *Queue) ReserveN(
	ctx context.Context, n int, waitTimeout time.Duration,
) ([]taskq.Job, error)

func (*Queue) String ¶

func (q *Queue) String() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL