sqs

Documentation

Index

• type SQSQueue
  • func NewSQSQueue(queueName string, region string) (*SQSQueue, error)
  • func (q *SQSQueue) FetchMessages() ([]string, error)
  • func (q *SQSQueue) PutMessages(messages []string) error

Types

type SQSQueue

type SQSQueue struct {
	URL    string
	Client sqsiface.SQSAPI
}

SQSQueue is a Queue with Amazon SQS.

func NewSQSQueue

func NewSQSQueue(queueName string, region string) (*SQSQueue, error)

NewSQSQueue creates a Queue with Amazon SQS.

func (*SQSQueue) FetchMessages

func (q *SQSQueue) FetchMessages() ([]string, error)

FetchMessages dequeue messages from SQS queue using long polling.

func (*SQSQueue) PutMessages

func (q *SQSQueue) PutMessages(messages []string) error

PutMessages enqueue given messages to SQS queue.

Since SQS supports at maximum 10 messages for one batch operation, we split the given slice by 10 times.