sqs

Documentation

Index

• Constants
• Variables
• func MessageInput(body []byte, queueURL string) *sqs.SendMessageInput
• func ReceiveMessage(api API, queueURL string) (*sqs.ReceiveMessageOutput, error)
• type API

Constants

const (
	AttributeSentAt = "SentAt"
	AttributeAll    = "All"

	FormatSentAt = "2006-01-02 15:04:05.999999999 -0700 MST"

	TypeString = "String"
)

Common Attributes.

Variables

var (
	TimeoutVisibility int64 = 60
	TimeoutWait       int64 = 10
)

Common Timeouts.

Functions

func MessageInput

func MessageInput(body []byte, queueURL string) *sqs.SendMessageInput

MessageInput given a queue url and a body creates a common message for to be sent over SQS.

func ReceiveMessage

func ReceiveMessage(api API, queueURL string) (*sqs.ReceiveMessageOutput, error)

ReceiveMessage given a queue url fetches the latest message with the common attributes and timeouts.

Types

type API

type API interface {
	DeleteMessage(*sqs.DeleteMessageInput) (*sqs.DeleteMessageOutput, error)
	GetQueueUrl(*sqs.GetQueueUrlInput) (*sqs.GetQueueUrlOutput, error)
	ReceiveMessage(*sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)
	SendMessage(*sqs.SendMessageInput) (*sqs.SendMessageOutput, error)
}

API bundles common SQS operations.