gosqs

Documentation

Index

• Variables
• func ChangeMessageVisibility(w http.ResponseWriter, req *http.Request)
• func CreateQueue(w http.ResponseWriter, req *http.Request)
• func DeleteMessage(w http.ResponseWriter, req *http.Request)
• func DeleteMessageBatch(w http.ResponseWriter, req *http.Request)
• func DeleteQueue(w http.ResponseWriter, req *http.Request)
• func GetQueueAttributes(w http.ResponseWriter, req *http.Request)
• func GetQueueUrl(w http.ResponseWriter, req *http.Request)
• func ListQueues(w http.ResponseWriter, req *http.Request)
• func PeriodicTasks(d time.Duration, quit <-chan struct{})
• func PurgeQueue(w http.ResponseWriter, req *http.Request)
• func ReceiveMessage(w http.ResponseWriter, req *http.Request)
• func SendMessage(w http.ResponseWriter, req *http.Request)
• func SendMessageBatch(w http.ResponseWriter, req *http.Request)
• func SetQueueAttributes(w http.ResponseWriter, req *http.Request)
• type DeleteEntry
• type SendEntry

Variables

var (
	ErrInvalidParameterValue = &app.SqsErrorType{
		HttpError: http.StatusBadRequest,
		Type:      "InvalidParameterValue",
		Code:      "AWS.SimpleQueueService.InvalidParameterValue",
		Message:   "An invalid or out-of-range value was supplied for the input parameter.",
	}
	ErrInvalidAttributeValue = &app.SqsErrorType{
		HttpError: http.StatusBadRequest,
		Type:      "InvalidAttributeValue",
		Code:      "AWS.SimpleQueueService.InvalidAttributeValue",
		Message:   "Invalid Value for the parameter RedrivePolicy.",
	}
)

Functions

func ChangeMessageVisibility

func ChangeMessageVisibility(w http.ResponseWriter, req *http.Request)

func CreateQueue

func CreateQueue(w http.ResponseWriter, req *http.Request)

func DeleteMessage

func DeleteMessage(w http.ResponseWriter, req *http.Request)

func DeleteMessageBatch

func DeleteMessageBatch(w http.ResponseWriter, req *http.Request)

func DeleteQueue

func DeleteQueue(w http.ResponseWriter, req *http.Request)

func GetQueueAttributes

func GetQueueAttributes(w http.ResponseWriter, req *http.Request)

func GetQueueUrl

func GetQueueUrl(w http.ResponseWriter, req *http.Request)

func ListQueues

func ListQueues(w http.ResponseWriter, req *http.Request)

func PeriodicTasks

func PeriodicTasks(d time.Duration, quit <-chan struct{})

func PurgeQueue

func PurgeQueue(w http.ResponseWriter, req *http.Request)

func ReceiveMessage

func ReceiveMessage(w http.ResponseWriter, req *http.Request)

func SendMessage

func SendMessage(w http.ResponseWriter, req *http.Request)

func SendMessageBatch

func SendMessageBatch(w http.ResponseWriter, req *http.Request)

func SetQueueAttributes

func SetQueueAttributes(w http.ResponseWriter, req *http.Request)

Types

type DeleteEntry

type DeleteEntry struct {
	Id            string
	ReceiptHandle string
	Error         string
	Deleted       bool
}

type SendEntry

type SendEntry struct {
	Id                     string
	MessageBody            string
	MessageAttributes      map[string]app.MessageAttributeValue
	MessageGroupId         string
	MessageDeduplicationId string
}