MCPcopy
hub / github.com/cortexlabs/cortex / MessageHandler

Interface MessageHandler

pkg/dequeuer/message_handler.go:21–23  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

19import "github.com/aws/aws-sdk-go/service/sqs"
20
21type MessageHandler interface {
22 Handle(*sqs.Message) error
23}
24
25func NewMessageHandlerFunc(handleFunc func(*sqs.Message) error) MessageHandler {
26 return &messageHandlerFunc{HandleFunc: handleFunc}

Callers 5

handleMessageMethod · 0.65
mainFunction · 0.65
mainFunction · 0.65
mainFunction · 0.65
mainFunction · 0.65

Implementers 3

AsyncMessageHandlerpkg/dequeuer/async_handler.go
BatchMessageHandlerpkg/dequeuer/batch_handler.go
messageHandlerFuncpkg/dequeuer/message_handler.go

Calls

no outgoing calls

Tested by

no test coverage detected