Versions in this module Expand all Collapse all v2 v2.2.4 Nov 12, 2020 Changes in this version + func NewFactory() taskq.Factory + type Queue struct + func NewQueue(opt *taskq.QueueOptions) *Queue + func (q *Queue) Add(msg *taskq.Message) error + func (q *Queue) Close() error + func (q *Queue) CloseTimeout(timeout time.Duration) error + func (q *Queue) Consumer() *taskq.Consumer + func (q *Queue) Delete(msg *taskq.Message) error + func (q *Queue) DeleteBatch(msgs []*taskq.Message) error + func (q *Queue) Len() (int, error) + func (q *Queue) Name() string + func (q *Queue) Options() *taskq.QueueOptions + func (q *Queue) Purge() error + func (q *Queue) Release(msg *taskq.Message) error + func (q *Queue) ReserveN(n int, waitTimeout time.Duration) ([]taskq.Message, error) + func (q *Queue) SetNoDelay(noDelay bool) + func (q *Queue) SetSync(sync bool) + func (q *Queue) String() string + func (q *Queue) WaitTimeout(timeout time.Duration) error Other modules containing this package github.com/airbrake/taskq
Go to main page