ssqs

Documentation

Overview

Package ssqs provides a super simple AWS SQS consumer.

Index

• Variables
• type Consumer
  • func New(q *Queue) *Consumer
  • func (c *Consumer) Close()
  • func (c *Consumer) Delete(m *Message) error
  • func (c *Consumer) Start()
• type Message
• type Queue

Variables

var DefaultClient = func(q *Queue) sqsiface.SQSAPI {
	return sqs.New(session.New(), &aws.Config{Region: &q.Region})
}

DefaultClient returns a new SQS client.

Types

type Consumer

type Consumer struct {
	Errors   chan error
	Messages chan Message
	Queue    *Queue
	// contains filtered or unexported fields
}

Consumer represents a consumer.

func New

func New(q *Queue) *Consumer

New creates and returns a consumer.

func (*Consumer) Close

func (c *Consumer) Close()

Close closes a consumer.

func (*Consumer) Delete

func (c *Consumer) Delete(m *Message) error

Delete deletes a message from the queue.

func (*Consumer) Start

func (c *Consumer) Start()

Start starts a consumer.

type Message

type Message struct {
	Body    string
	ID      string
	Receipt string
}

Message represents a queue message.

type Queue

type Queue struct {
	Name              string
	PollDuration      int64
	Region            string
	URL               string
	VisibilityTimeout int64
}

Queue represents a consumers queue.