dispatch

Documentation

Index

• type Queue
  • func NewQueue(config *aws.Config, name string) (q *Queue, err error)
  • func (q *Queue) Send(message string) error

Types

type Queue

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

Queue wraps an SQS reference

func NewQueue

func NewQueue(config *aws.Config, name string) (q *Queue, err error)

NewQueue initializes the state of the queue struct by fetching the queue URL from AWS

func (*Queue) Send

func (q *Queue) Send(message string) error

Send will put a message on the SQS queue