amzsqs

Documentation

Index

• func NewFifoQueue(opts *Options) (amboy.Queue, error)
• type Options
  • func (opts *Options) Validate() error

Functions

func NewFifoQueue

func NewFifoQueue(opts *Options) (amboy.Queue, error)

NewFifoQueue constructs a AWS SQS backed Queue implementation. This queue, generally is ephemeral: tasks are removed from the queue, and therefore may not handle jobs across restarts.

Types

type Options

type Options struct {
	Name       string
	Region     string
	NumWorkers int
	Logger     grip.Journaler
}

Options holds the creation options. If region is not specified, it defaults to "us-east-1" and if the journaler is not specified, the global journal is used.

func (*Options) Validate

func (opts *Options) Validate() error