sqs

Documentation

Index

• type Provider
  • func NewSqsProvider(region, key, secret, queue string) *Provider
  • func (mgr Provider) Close() error
  • func (mgr Provider) DeleteMessage(reference *string) error
  • func (mgr Provider) GetNextMessage() (*message.Message, error)
  • func (mgr Provider) SendMessage(msg *message.Message) error

Types

type Provider

type Provider struct {
	QueueURL  *string
	QueueName *string
	// contains filtered or unexported fields
}

Provider represents an SQS queue.

func NewSqsProvider

func NewSqsProvider(region, key, secret, queue string) *Provider

NewSqsProvider is a convenience method to return a new *Provider instance.

func (Provider) Close

func (mgr Provider) Close() error

Close implemented to satisfy Provider interface.

func (Provider) DeleteMessage

func (mgr Provider) DeleteMessage(reference *string) error

DeleteMessage implements the required interface method to be a Provider. This method deletes a message from the queue.

func (Provider) GetNextMessage

func (mgr Provider) GetNextMessage() (*message.Message, error)

GetNextMessage implements the required interface method to be a Provider. This method sends a ReceiveMessageInput message to SQS and converts the message into a *task.Task object.

func (Provider) SendMessage

func (mgr Provider) SendMessage(msg *message.Message) error

SendMessage implements the required interface method to be a Provider. This method sends a new SQS SendMessageInput message to SQS.