Functions — github.com/bufferapp/sqs-worker-go

CodeHub MCPcopy Create free account

hub / github.com/bufferapp/sqs-worker-go / functions

Functions14 in github.com/bufferapp/sqs-worker-go

⨍ Functions 14 ◇ Types & classes 4

↓ 5 callersMethodError

worker/worker.go:33

↓ 2 callersFunctionNewService

NewService creates new worker service

worker/worker.go:68

↓ 1 callersMethodHandleMessage

(msg *sqs.Message)

worker/worker.go:24

↓ 1 callersFunctionhandleMessage

(s *Service, m *sqs.Message, h Handler)

worker/worker.go:138

↓ 1 callersFunctionrun

poll launches goroutine per received message and wait for all message to be processed

worker/worker.go:116

↓ 1 callersFunctionsetup

worker/worker_test.go:23

↓ 1 callersMethodshouldBackup

worker/worker.go:134

↓ 1 callersFunctionteardown

worker/worker_test.go:47

Backup to set up Firehose backup option

worker/worker.go:60

MethodHandleMessage

HandleMessage is used for the actual execution of each message

worker/worker.go:18

FunctionNewInvalidMessageError

NewInvalidMessageError to create new error for messages that should be deleted

worker/worker.go:38

Start starts the polling and will continue polling till the application is forcibly stopped

worker/worker.go:93

FunctionTestMain

worker/worker_test.go:67

FunctionTestNewService

worker/worker_test.go:80