azsqs

Documentation

Index

• func NewManager(sqs *sqs.SQS, accountId string) msgqueue.Manager
• type Queue
  • func NewQueue(sqs *sqs.SQS, accountId string, opt *msgqueue.Options) *Queue
  • func Queues() []*Queue
  • func (q *Queue) Add(msg *msgqueue.Message) error
  • func (q *Queue) Call(args ...interface{}) error
  • func (q *Queue) CallOnce(period time.Duration, args ...interface{}) error
  • func (q *Queue) Close() error
  • func (q *Queue) CloseTimeout(timeout time.Duration) error
  • func (q *Queue) Delete(msg *msgqueue.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() *msgqueue.Options
  • func (q *Queue) Processor() *msgqueue.Processor
  • func (q *Queue) Purge() error
  • 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

Functions

func NewManager

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

Types

type Queue

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

func NewQueue

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

func Queues

func Queues() []*Queue

func (*Queue) Add

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

Add adds message to the queue.

func (*Queue) Call

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

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

func (*Queue) CallOnce

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 (*Queue) Close

func (q *Queue) Close() error

Close is CloseTimeout with 30 seconds timeout.

func (*Queue) CloseTimeout

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

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

func (*Queue) Delete

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

Delete deletes the message from the queue.

func (*Queue) GetAddQueue

func (q *Queue) GetAddQueue() *memqueue.Queue

func (*Queue) GetDeleteQueue

func (q *Queue) GetDeleteQueue() *memqueue.Queue

func (*Queue) Len

func (q *Queue) Len() (int, error)

func (*Queue) Name

func (q *Queue) Name() string

func (*Queue) Options

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

func (*Queue) Processor

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

func (*Queue) Purge

func (q *Queue) Purge() error

Purge deletes all messages from the queue using SQS API.

func (*Queue) Release

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

func (*Queue) ReserveN

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

func (*Queue) String

func (q *Queue) String() string