sqs

Documentation

Index

• type Config
• type SQS
  • func New(cfg Config) SQS
  • func NewNoCreds(url, region string, timeout int) SQS
  • func NewWithSession(url, region string, timeout int, sess *session.Session) SQS
  • func (instance SQS) Append(queue, msg string) (err error)
  • func (instance SQS) Complete(queue, messageID string) (err error)
  • func (instance SQS) Next(queue string) (messageID, result string, err error)

Types

type Config

type Config struct {
	Secret         string
	Access         string
	URL            string
	Region         string
	MessageTimeout int
}

type SQS

type SQS struct {
	// contains filtered or unexported fields
}

func New

func New(cfg Config) SQS

New returns an instance of SQS

func NewNoCreds

func NewNoCreds(url, region string, timeout int) SQS

NewNoCreds returns an instance of SQS using default credentials, fall back to env...

func NewWithSession

func NewWithSession(url, region string, timeout int, sess *session.Session) SQS

NewWithSession returns an instance of SQS using a passed session

func (SQS) Append

func (instance SQS) Append(queue, msg string) (err error)

func (SQS) Complete

func (instance SQS) Complete(queue, messageID string) (err error)

Complete lets SQS know that a message was successfully processed.

func (SQS) Next

func (instance SQS) Next(queue string) (messageID, result string, err error)

Next returns the next SQS message.