queue

Documentation

Index

• type Queue
  • func NewQueue() (queue *Queue)
  • func (q *Queue) Poll()
  • func (q *Queue) Publish(p *page.Page)

Types

type Queue

type Queue struct {
	ReceiveChan chan *sqs.Message
	Svc         *sqs.SQS
}

func NewQueue

func NewQueue() (queue *Queue)

func (*Queue) Poll

func (q *Queue) Poll()

func (*Queue) Publish

func (q *Queue) Publish(p *page.Page)