sqs

package
v1.2.0 Latest Latest
Warning

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

Go to latest
Published: Oct 15, 2023 License: MPL-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrInvalidCredentials = errors.New("your sqs credentials are invalid. please verify you're providing the correct credentials")

Functions

This section is empty.

Types

type Sqs

type Sqs struct {
	Cfg *datastore.SQSPubSubConfig
	// contains filtered or unexported fields
}

func New

func New(source *datastore.Source, handler datastore.PubSubHandler, log log.StdLogger) *Sqs

func (*Sqs) Consume

func (s *Sqs) Consume()

func (*Sqs) Start

func (s *Sqs) Start()

func (*Sqs) Stop

func (s *Sqs) Stop()

func (*Sqs) Verify

func (s *Sqs) Verify() error

Verify ensures the sqs credentials are correct

Jump to

Keyboard shortcuts

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