queue

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 23, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Queue

type Queue interface {

	// Send a message on the Queue
	Send(interface{}) error

	// Receive a message from the Queue
	Receive(interface{}) (bool, error)

	// Name of the queue
	Name() string

	// Delete the queue
	Delete() error
}

Queue used to send and receive Messages

func CreateSQS

func CreateSQS(ctx context.Context, api sqsiface.SQSAPI, name string) (Queue, error)

CreateSQS returns a newly created SQS queue

func NewSQS

func NewSQS(api sqsiface.SQSAPI, name string) Queue

NewSQS returns a Queue backed by SQS

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL