sqs

Documentation

Overview

Package sqs contains helpers for AWS SQS.

Index

• func CreateQueue(sqsClient sqsiface.SQSAPI, f *framework.Framework) string
• func DeleteQueue(sqsClient sqsiface.SQSAPI, url string)
• func QueueARN(sqsClient sqsiface.SQSAPI, url string) string
• func ReceiveMessages(sqsClient sqsiface.SQSAPI, url string) []*sqs.Message
• func SendMessage(sqsClient sqsiface.SQSAPI, url string) string

Functions

func CreateQueue

func CreateQueue(sqsClient sqsiface.SQSAPI, f *framework.Framework) string

CreateQueue creates a queue named after the given framework.Framework.

func DeleteQueue

func DeleteQueue(sqsClient sqsiface.SQSAPI, url string)

DeleteQueue deletes the queue with the given URL.

func QueueARN

func QueueARN(sqsClient sqsiface.SQSAPI, url string) string

QueueARN returns the ARN of the queue with the given URL.

func ReceiveMessages

func ReceiveMessages(sqsClient sqsiface.SQSAPI, url string) []*sqs.Message

ReceiveMessages retrieves messages from the queue with the given URL.

func SendMessage

func SendMessage(sqsClient sqsiface.SQSAPI, url string) string

SendMessage sends a message to the queue with the given URL.