sqs

Documentation

Index

• type Queue
  • func NewQueue(c map[string]any) (*Queue, error)
  • func (q *Queue) Dequeue() ([]byte, bool)
  • func (q *Queue) Enqueue(message []byte) error

Types

type Queue

type Queue struct {
	URL             string `mapstructure:"url"`
	AccessKeyId     string `mapstructure:"access_key_id"`
	SecretAccessKey string `mapstructure:"secret_access_key"`
	Region          string `mapstructure:"region"`
	// contains filtered or unexported fields
}

Queue implements queue.QueueBackend using SQS

func NewQueue

func NewQueue(c map[string]any) (*Queue, error)

NewQueue returns a new initialized Queue

func (*Queue) Dequeue

func (q *Queue) Dequeue() ([]byte, bool)

Dequeue implememnts queue.QueueBackend.Dequeue

func (*Queue) Enqueue

func (q *Queue) Enqueue(message []byte) error

Enqueue implements queue.QueueBackend.Enqueue