sqs_common

Documentation

Index

• func GetCredentials(t, akid, secret string) (*credentials.Credentials, error)
• type Config
• type SQS
  • func SQSListener(c *Config) (*SQS, error)
  • func (s *SQS) DeleteMessages(m []*sqs.Message, lg *log.Logger) error
  • func (s *SQS) GetMessages() ([]*sqs.Message, error)

Functions

func GetCredentials

func GetCredentials(t, akid, secret string) (*credentials.Credentials, error)

Types

type Config

type Config struct {
	Queue       string
	Region      string
	Credentials *credentials.Credentials
}

type SQS

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

func SQSListener

func SQSListener(c *Config) (*SQS, error)

Creates a new SQS connection from a given Config object.

func (*SQS) DeleteMessages

func (s *SQS) DeleteMessages(m []*sqs.Message, lg *log.Logger) error

func (*SQS) GetMessages

func (s *SQS) GetMessages() ([]*sqs.Message, error)

Returns one or more messages from the queue on this SQS object.