sqs

Documentation

Overview

Package sqs handles interactions with aws-sdk-go/service/sqs

Index

• Constants
• func NewCreateQueueInput(queueName string) (*sqs.CreateQueueInput, error)
• func NewGetQueueAttributesInput(queueUrl string) (*sqs.GetQueueAttributesInput, error)
• func NewGetQueueUrlInput(queueName string) (*sqs.GetQueueUrlInput, error)
• func NewSendMessageInput(input interface{}, queueUrl string, base64Encode bool) (*sqs.SendMessageInput, error)
• type GetQueueUrlInput
• type SQS
  • func New(svc *pkgAws.Session, endpoint string) (*SQS, error)
  • func (svc *SQS) SQSCreateQueue(queue string) error
  • func (svc *SQS) SQSGetQueueAttributes(queueUrl string) (*sqs.GetQueueAttributesOutput, error)
  • func (svc *SQS) SQSGetQueueUrl(queueUrl string) (string, error)
  • func (svc *SQS) SQSSendMessage(input interface{}, queueName string, base64Encode bool) error

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"
)

const (

	// QueueName represents a parameter named queueName
	QueueName = "queueName"
	// QueueUrl represents a parameter named queueUrl
	QueueUrl = "queueUrl"
	// Input represents a parameter named input
	Input = "input"
)

Functions

func NewCreateQueueInput

func NewCreateQueueInput(queueName string) (*sqs.CreateQueueInput, error)

NewCreateQueueInput creates a new queue given its name

func NewGetQueueAttributesInput

func NewGetQueueAttributesInput(queueUrl string) (*sqs.GetQueueAttributesInput, error)

NewGetQueueAttributesInput returns a new *sqs.GetQueueAttributesInput given a queueUrl

func NewGetQueueUrlInput

func NewGetQueueUrlInput(queueName string) (*sqs.GetQueueUrlInput, error)

NewGetQueueUrlInput returns a new *sqs.GetQueueUrlInput given a queue name

func NewSendMessageInput

func NewSendMessageInput(input interface{}, queueUrl string, base64Encode bool) (*sqs.SendMessageInput, error)

NewSendMessageInput returns a new *sqs.SendMessageInput initialized with queueUrl and messageBody. If base64Encode = true then the messageBody will be encoded in base64

Types

type GetQueueUrlInput

type GetQueueUrlInput struct {
	*sqs.GetQueueUrlInput
}

GetQueueUrlInput embeds *sqs.GetQueueUrlInput

type SQS

type SQS struct {
	*sqs.SQS
}

SQS embeds *sns.SNS

func New

func New(svc *pkgAws.Session, endpoint string) (*SQS, error)

New returns a new *SQS

func (*SQS) SQSCreateQueue

func (svc *SQS) SQSCreateQueue(queue string) error

SQSCreateQueue creates an sns queue given a queue name

func (*SQS) SQSGetQueueAttributes

func (svc *SQS) SQSGetQueueAttributes(queueUrl string) (*sqs.GetQueueAttributesOutput, error)

SQSGetQueueAttributes returns error if queue does not exist, get queue attributes otherwise

func (*SQS) SQSGetQueueUrl

func (svc *SQS) SQSGetQueueUrl(queueUrl string) (string, error)

SQSGetQueueUrl gets a queue's url given its name

func (*SQS) SQSSendMessage

func (svc *SQS) SQSSendMessage(input interface{}, queueName string, base64Encode bool) error

SQSSendMessage sends a message on SQS