Documentation
¶
Overview ¶
Package sqs handles interactions with aws-sdk-go/service/sqs
Index ¶
Constants ¶
const ( // ErrNoPointerParameterAllowed is used when a ptr parameter is not allowed ErrNoPointerParameterAllowed = "NoPointerParameterAllowed" // ErrEmptyParameter is used when a required parameter is empty ErrEmptyParameter = "EmptyParameter" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CreateQueueInput ¶
type CreateQueueInput struct {
*sqs.CreateQueueInput
}
CreateQueueInput embeds *sqs.CreateQueueInput
func NewCreateQueueInput ¶
func NewCreateQueueInput(queueName string) (*CreateQueueInput, error)
NewCreateQueueInput creates a new queue given its name
type GetQueueAttributesInput ¶
type GetQueueAttributesInput struct {
*sqs.GetQueueAttributesInput
}
GetQueueAttributesInput embeds *sqs.GetQueueAttributesInput
func NewGetQueueAttributesInput ¶
func NewGetQueueAttributesInput(queueUrl string) (*GetQueueAttributesInput, error)
NewGetQueueAttributesInput returns a new *GetQueueAttributesInput given a queueUrl
type GetQueueAttributesOutput ¶
type GetQueueAttributesOutput struct {
*sqs.GetQueueAttributesOutput
}
GetQueueAttributesOutput embeds *sqs.GetQueueAttributesOutput
type SQS ¶
SQS embeds *sns.SNS
func (*SQS) SQSCreateQueue ¶
func (svc *SQS) SQSCreateQueue(input *CreateQueueInput) error
SQSCreateQueue creates an sns queue given a *CreateQueueInput
func (*SQS) SQSGetQueueAttributes ¶
func (svc *SQS) SQSGetQueueAttributes(input *GetQueueAttributesInput) (*GetQueueAttributesOutput, error)
SQSGetQueueAttributes returns error if queue does not exist, nil otherwise
func (*SQS) SQSSendMessage ¶
func (svc *SQS) SQSSendMessage(input *SendMessageInput) error
SQSSendMessage sends a message on SQS
type SendMessageInput ¶
type SendMessageInput struct {
*sqs.SendMessageInput
}
SendMessageInput embeds *sqs.SendMessageInput
func NewSendMessageInput ¶
func NewSendMessageInput(input interface{}, queueUrl string) (*SendMessageInput, error)
NewSendMessageInput returns a new *SendMessageInput initialized with queueUrl and messageBody encoded in base64
Source Files