Documentation
¶
Index ¶
- func CreateAttributesParams(url *string) *sqs.GetQueueAttributesInput
- func CreateInputParam(queueName string) *sqs.CreateQueueInput
- func CreateNewQueue(params *sqs.CreateQueueInput) (*sqs.CreateQueueOutput, error)
- func CreateSendMessageBatchInput(url *string, body *string, acid *string, ot string, ct string, num int) (params *sqs.SendMessageBatchInput)
- func CreateSendMessageInput(url *string, body *string, acid *string, ot string, ct string) (params *sqs.SendMessageInput)
- func GetQueueAttributes(params *sqs.GetQueueAttributesInput) (*sqs.GetQueueAttributesOutput, error)
- func New()
- func PurgeQueue(url *string)
- func SendMessageToQueue(params *sqs.SendMessageInput)
- func SendMultipleMessagesToQueue(params *sqs.SendMessageBatchInput)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateAttributesParams ¶
func CreateAttributesParams(url *string) *sqs.GetQueueAttributesInput
CreateAttributesParams is to create attribute parameter
func CreateInputParam ¶
func CreateInputParam(queueName string) *sqs.CreateQueueInput
CreateInputParam is to create input parameter
func CreateNewQueue ¶
func CreateNewQueue(params *sqs.CreateQueueInput) (*sqs.CreateQueueOutput, error)
CreateNewQueue is to create new queue
func CreateSendMessageBatchInput ¶
func CreateSendMessageBatchInput(url *string, body *string, acid *string, ot string, ct string, num int) (params *sqs.SendMessageBatchInput)
CreateSendMessageBatchInput is to create input parameter for batch up to ten messages!!
func CreateSendMessageInput ¶
func CreateSendMessageInput(url *string, body *string, acid *string, ot string, ct string) (params *sqs.SendMessageInput)
CreateSendMessageInput is to create input parameter TODO:このAttributesのパラメータは動的に変更せねばならない。 TODO:contentTypeも動的に変更できるように
func GetQueueAttributes ¶
func GetQueueAttributes(params *sqs.GetQueueAttributesInput) (*sqs.GetQueueAttributesOutput, error)
GetQueueAttributes to get queue attributes
func PurgeQueue ¶
func PurgeQueue(url *string)
PurgeQueue is to purge queue 削除するタイミングに制限あり(一定間隔内における連続削除はできない) http://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_PurgeQueue.html
func SendMessageToQueue ¶
func SendMessageToQueue(params *sqs.SendMessageInput)
SendMessageToQueue is to send message to queue
func SendMultipleMessagesToQueue ¶
func SendMultipleMessagesToQueue(params *sqs.SendMessageBatchInput)
SendMultipleMessagesToQueue is to send multiple messages to queue
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.