queue

Documentation

Index

• type Message
  • func (m Message) Body() (*event.Event, error)
  • func (m Message) Delete() error
  • func (m Message) Visibility() error
• type Queue
  • func (q Queue) Read() (*Message, error)

Types

type Message

type Message struct {
	Base *types.Base
	Msg  *sqs.Message
	SQS  sqs.SQS
}

Message an SQS message wrapper

func (Message) Body

func (m Message) Body() (*event.Event, error)

Body return the message event body

func (Message) Delete

func (m Message) Delete() error

Delete the message

func (Message) Visibility

func (m Message) Visibility() error

Visibility set configured error visibility timeout

type Queue

type Queue struct {
	Base *types.Base
	SQS  sqs.SQS
}

Queue an SQS queue wrapper

func (Queue) Read

func (q Queue) Read() (*Message, error)