Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewHTTPClientWithSettings ¶
func NewHTTPClientWithSettings(httpSettings HTTPClientSettings) (*http.Client, error)
Types ¶
type Client ¶
type Client interface { QueueURL(queueName string) string CreateQueue(queueName string) (*sqs.CreateQueueOutput, error) DeleteQueue(queueName string) (*sqs.DeleteQueueOutput, error) SendMessage(kw SendMessageModel) (*sqs.SendMessageOutput, error) ReceiveMessage(kw ReceiveMessageModel) (*sqs.ReceiveMessageOutput, error) DeleteMessage(kw DeleteMessageModel) (*sqs.DeleteMessageOutput, error) SendMessageBatch(kw SendMessageBatchModel) (*sqs.SendMessageBatchOutput, error) DeleteMessageBatch(kw DeleteMessageBatchModel) (*sqs.DeleteMessageBatchOutput, error) }
type ClientModel ¶
type DeleteMessageBatchModel ¶
type DeleteMessageBatchModel struct { QueueName *string Entries []*sqs.DeleteMessageBatchRequestEntry }
type DeleteMessageModel ¶
type HTTPClientSettings ¶
type ReceiveMessageModel ¶
type ReceiveMessageModel struct { QueueName *string MaxNumberOfMessages *int64 WaitTimeSeconds *int64 VisibilityTimeout *int64 //A list of attributes that need to be returned along with each message //e.g. ApproximateNumberOfMessages, ApproximateNumberOfMessagesDelayed AttributeNames []*string //The name of the message attribute, where N is the index. The message attribute MessageAttributeNames []*string }
type SendMessageBatchModel ¶
type SendMessageBatchModel struct { QueueName *string //Contains the details of a single Amazon SQS message along with a Id. Entries []*sqs.SendMessageBatchRequestEntry }
type SendMessageModel ¶
Click to show internal directories.
Click to hide internal directories.