Versions in this module Expand all Collapse all v3 v3.2.4 Nov 17, 2020 v3.2.3 Nov 17, 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(ctx context.Context, 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/vickxxx/taskq
Go to main page