sqs

func CreateQueue ¶

func CreateQueue(cli sqsiface.SQSAPI, name string, tags map[string]string) (string, error)

CreateQueue creates a queue with the given name and optional tags.

Naming restrictions are described at https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_CreateQueue.html

func DeleteQueue ¶

func DeleteQueue(cli sqsiface.SQSAPI, url string) error

DeleteQueue deletes the queue with the given URL.

func QueueARN ¶

func QueueARN(cli sqsiface.SQSAPI, url string) (string, error)

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

func QueueAttributes ¶

func QueueAttributes(cli sqsiface.SQSAPI, url string, attrs []string) (map[string]string, error)

QueueAttributes returns selected attributes of the queue with the given URL.

func QueuePolicy ¶

func QueuePolicy(cli sqsiface.SQSAPI, url string) (string, error)

QueuePolicy returns the policy of the queue with the given URL.

func QueueTags ¶

func QueueTags(cli sqsiface.SQSAPI, url string) (map[string]string, error)

QueueTags returns the tags of the queue with the given URL.

func QueueURL ¶

func QueueURL(cli sqsiface.SQSAPI, name string) (string, error)

QueueURL returns the URL of the queue identified by name.

func SetQueuePolicy ¶

func SetQueuePolicy(cli sqsiface.SQSAPI, url string, pol iam.Policy) error

SetQueuePolicy sets the Policy attribute of the queue with the given URL.

See also https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-authentication-and-access-control.html