sqs

Documentation

Overview

Package sqs contains helpers for AWS SQS.

Index

• func CreateQueue(cli sqsiface.SQSAPI, name string, tags map[string]string) (string, error)
• func DeleteQueue(cli sqsiface.SQSAPI, url string) error
• func QueueARN(cli sqsiface.SQSAPI, url string) (string, error)
• func QueueAttributes(cli sqsiface.SQSAPI, url string, attrs []string) (map[string]string, error)
• func QueuePolicy(cli sqsiface.SQSAPI, url string) (string, error)
• func QueueTags(cli sqsiface.SQSAPI, url string) (map[string]string, error)
• func QueueURL(cli sqsiface.SQSAPI, name string) (string, error)
• func SetQueuePolicy(cli sqsiface.SQSAPI, url string, pol iam.Policy) error

Functions

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