sqs

package
v0.0.0-...-37e8840 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 17, 2020 License: MIT Imports: 4 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL