sqs

package
v0.0.0-...-02fc557 Latest Latest
Warning

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

Go to latest
Published: Dec 23, 2022 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Driver

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

func New

func New(options ...Option) (*Driver, error)

func (*Driver) Ack

func (c *Driver) Ack(queue, messageID string) error

func (*Driver) Consume

func (d *Driver) Consume(ctx context.Context, queue string) (chan driver.Message, error)

func (*Driver) Enqueue

func (d *Driver) Enqueue(queue string, data []byte) error

type Option

type Option func(*Driver)

func AutoTestConnection

func AutoTestConnection() Option

func WithClient

func WithClient(c sqsClient) Option

func WithMaxNumberOfMessages

func WithMaxNumberOfMessages(val int64) Option

func WithRegion

func WithRegion(region string) Option

func WithUrl

func WithUrl(name string) Option

func WithVisibilityTimeout

func WithVisibilityTimeout(val int64) Option

Directories

Path Synopsis
Package mock_sqs is a generated GoMock package.
Package mock_sqs is a generated GoMock package.

Jump to

Keyboard shortcuts

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