gosqs

Documentation

Index

• func ChangeMessageVisibilityV1(req *http.Request) (int, interfaces.AbstractResponseBody)
• func CreateQueueV1(req *http.Request) (int, interfaces.AbstractResponseBody)
• func DeleteMessageBatchV1(req *http.Request) (int, interfaces.AbstractResponseBody)
• func DeleteMessageV1(req *http.Request) (int, interfaces.AbstractResponseBody)
• func DeleteQueueV1(req *http.Request) (int, interfaces.AbstractResponseBody)
• func GetQueueAttributesV1(req *http.Request) (int, interfaces.AbstractResponseBody)
• func GetQueueUrlV1(req *http.Request) (int, interfaces.AbstractResponseBody)
• func ListQueuesV1(req *http.Request) (int, interfaces.AbstractResponseBody)
• func PeriodicTasks(d time.Duration, quit chan bool)
• func PurgeQueueV1(req *http.Request) (int, interfaces.AbstractResponseBody)
• func ReceiveMessageV1(req *http.Request) (int, interfaces.AbstractResponseBody)
• func SendMessageBatchV1(req *http.Request) (int, interfaces.AbstractResponseBody)
• func SendMessageV1(req *http.Request) (int, interfaces.AbstractResponseBody)
• func SetQueueAttributesV1(req *http.Request) (int, interfaces.AbstractResponseBody)

Functions

func ChangeMessageVisibilityV1

func ChangeMessageVisibilityV1(req *http.Request) (int, interfaces.AbstractResponseBody)

func CreateQueueV1

func CreateQueueV1(req *http.Request) (int, interfaces.AbstractResponseBody)

func DeleteMessageBatchV1

func DeleteMessageBatchV1(req *http.Request) (int, interfaces.AbstractResponseBody)

func DeleteMessageV1

func DeleteMessageV1(req *http.Request) (int, interfaces.AbstractResponseBody)

func DeleteQueueV1

func DeleteQueueV1(req *http.Request) (int, interfaces.AbstractResponseBody)

func GetQueueAttributesV1

func GetQueueAttributesV1(req *http.Request) (int, interfaces.AbstractResponseBody)

func GetQueueUrlV1

func GetQueueUrlV1(req *http.Request) (int, interfaces.AbstractResponseBody)

func ListQueuesV1

func ListQueuesV1(req *http.Request) (int, interfaces.AbstractResponseBody)

TODO - set up MaxResults, NextToken request params

https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_ListQueues.html

func PeriodicTasks

func PeriodicTasks(d time.Duration, quit chan bool)

func PurgeQueueV1

func PurgeQueueV1(req *http.Request) (int, interfaces.AbstractResponseBody)

func ReceiveMessageV1

func ReceiveMessageV1(req *http.Request) (int, interfaces.AbstractResponseBody)

TODO - Admiral-Piett - could we refactor the way we hide messages? Change data structure to a queue organized by "reveal time" or a map with the key being a timestamp of when it could be shown? Ordered Map - https://github.com/elliotchance/orderedmap

func SendMessageBatchV1

func SendMessageBatchV1(req *http.Request) (int, interfaces.AbstractResponseBody)

func SendMessageV1

func SendMessageV1(req *http.Request) (int, interfaces.AbstractResponseBody)

func SetQueueAttributesV1

func SetQueueAttributesV1(req *http.Request) (int, interfaces.AbstractResponseBody)