azsqs

package

v1.8.2 Latest Latest Go to latest Published: Aug 27, 2018 License: BSD-2-Clause Imports: 12 Imported by: 0

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

This section is empty.

This section is empty.

func NewManager(sqs *sqs.SQS, accountId string) msgqueue.Manager

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

func NewQueue(sqs *sqs.SQS, accountId string, opt *msgqueue.Options) *Queue

func Queues() []*Queue

func (q *Queue) Add(msg *msgqueue.Message) error

Add adds message to the queue.

func (q *Queue) Call(args ...interface{}) error

Call creates a message using the args and adds it to the queue.

func (q *Queue) CallOnce(period time.Duration, args ...interface{}) error

CallOnce works like Call, but it returns ErrDuplicate if message with such args was already added in a period.

func (q *Queue) Close() error

Close is CloseTimeout with 30 seconds timeout.

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

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

func (q *Queue) Delete(msg *msgqueue.Message) error

Delete deletes the message from the queue.

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() *msgqueue.Options

func (q *Queue) Processor() *msgqueue.Processor

func (q *Queue) Purge() error

Purge deletes all messages from the queue using SQS API.

func (q *Queue) Release(msg *msgqueue.Message) error

func (q *Queue) ReserveN(n int, reservationTimeout time.Duration, waitTimeout time.Duration) ([]*msgqueue.Message, error)

func (q *Queue) String() string