sqs

Apr 9, 2024

Changes in this version

+ func InvalidationQueueMessageParser(rawMessage types.Message) (dedup.QueueMessage, error)

+ type InvalidationQueueMessage struct

+ Data InvalidationQueueMessageData

+ func (m InvalidationQueueMessage) MessageID() string

+ func (m InvalidationQueueMessage) ReceiptHandle() string

+ func (m InvalidationQueueMessage) UniqueID() string

+ type InvalidationQueueMessageData struct

+ UUID string

+ type Queue struct

+ func NewQueue(queueConfig *QueueConfig) *Queue

+ func (q *Queue) DeleteMessagesBatch(receiptHandles []string)

+ func (q *Queue) PullMessagesBatch() ([]dedup.QueueMessage, error)

+ func (q *Queue) ResetVisibilityBatch(receiptHandles []string)

+ type QueueConfig struct

+ MessageParser messageParser

+ ProfileName string

+ QueueUrl *string