The highest tagged major version is
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type QueueManager ¶
type QueueManager struct {
PollDelay time.Duration
WaitTimeSeconds int64
VisibilityTimeout int64
// contains filtered or unexported fields
}
QueueManager is an sqs queue manager
func NewQueueManager ¶
func NewQueueManager(sqs *sqs.SQS) *QueueManager
NewQueueManager contructs a new queue manager
func (*QueueManager) Scan ¶
func (q *QueueManager) Scan(ctx context.Context, queue string, backlog int64) <-chan *QueueMessage
Scan begins scanning a queue
func (*QueueManager) Wait ¶
func (q *QueueManager) Wait()
Wait waits for all of the queues to close down
type QueueMessage ¶
QueueMessage is a wrapper arround the sqs.Message
func (*QueueMessage) Delete ¶
func (m *QueueMessage) Delete() error
Delete deletes the message from the queue
Source Files
Click to show internal directories.
Click to hide internal directories.