sqs

Documentation

Index

• func InvalidationQueueMessageParser(rawMessage types.Message) (dedup.QueueMessage, error)
• type InvalidationQueueMessage
  • func (m InvalidationQueueMessage) MessageID() string
  • func (m InvalidationQueueMessage) ReceiptHandle() string
  • func (m InvalidationQueueMessage) UniqueID() string
• type InvalidationQueueMessageData
• type Queue
  • 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

Functions

func InvalidationQueueMessageParser

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

Types

type InvalidationQueueMessage

type InvalidationQueueMessage struct {
	Data InvalidationQueueMessageData `json:"data"`
	// contains filtered or unexported fields
}

func (InvalidationQueueMessage) MessageID

func (m InvalidationQueueMessage) MessageID() string

func (InvalidationQueueMessage) ReceiptHandle

func (m InvalidationQueueMessage) ReceiptHandle() string

func (InvalidationQueueMessage) UniqueID

func (m InvalidationQueueMessage) UniqueID() string

type InvalidationQueueMessageData

type InvalidationQueueMessageData struct {
	UUID string `json:"uuid"`
}

type Queue

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

func NewQueue

func NewQueue(queueConfig *QueueConfig) *Queue

func (*Queue) DeleteMessagesBatch

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

func (*Queue) PullMessagesBatch

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

func (*Queue) ResetVisibilityBatch

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

type QueueConfig

type QueueConfig struct {
	QueueUrl      *string
	ProfileName   string
	MessageParser messageParser
}