Documentation ¶
Index ¶
- func NewFactory(db *bun.DB) taskq.Factory
- type Job
- type Queue
- func (q *Queue) AddJob(ctx context.Context, job *taskq.Job) error
- func (q *Queue) Close() error
- func (q *Queue) CloseTimeout(timeout time.Duration) error
- func (q *Queue) Consumer() taskq.QueueConsumer
- func (q *Queue) Delete(ctx context.Context, job *taskq.Job) error
- func (q *Queue) Len(ctx context.Context) (int, error)
- func (q *Queue) Name() string
- func (q *Queue) Options() *taskq.QueueConfig
- func (q *Queue) Purge(ctx context.Context) error
- func (q *Queue) Release(ctx context.Context, job *taskq.Job) error
- func (q *Queue) ReserveN(ctx context.Context, n int, waitTimeout time.Duration) ([]taskq.Job, error)
- func (q *Queue) String() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFactory ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.