Documentation ¶
Index ¶
- func NewFactory(sqs *sqs.SQS, accountID string) taskq.Factory
- type 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) GetAddQueue() *memqueue.Queue
- func (q *Queue) GetDeleteQueue() *memqueue.Queue
- 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) String() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFactory ¶
Types ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
func (*Queue) CloseTimeout ¶
CloseTimeout closes the queue waiting for pending messages to be processed.
func (*Queue) GetAddQueue ¶
func (*Queue) GetDeleteQueue ¶
Click to show internal directories.
Click to hide internal directories.