Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageProcessor ¶
type MessageProcessor struct {
// contains filtered or unexported fields
}
MessageProcessor reads and processes messages off of an AWS SQS queue.
func NewMessageProcessor ¶
func NewMessageProcessor(awsSQSClient *sqs.SQS, awsSQSQueueURL string, awsSQSQueueMaxNumberOfMessages int64, awsSQSQueueMaxWaitTimeSeconds int64, awsSQSQueueVisibilityTimeoutSeconds int64, controller types.Controller) *MessageProcessor
NewMessageProcessor creates a new instance of MessageProcessor.
func (*MessageProcessor) Run ¶
func (p *MessageProcessor) Run()
Run sits on a loop reading and processing messages off of the AWS SQS queue.
type ResponseProcessor ¶
type ResponseProcessor struct {
// contains filtered or unexported fields
}
ResponseProcessor processes responses to functions invocations made while processing messages off of an AWS SQS queue.
func NewResponseProcessor ¶
func NewResponseProcessor(awsSQSClient *sqs.SQS, awsSQSQueueURL string) *ResponseProcessor
NewResponseProcessor creates a new instance of ResponseProcessor.
func (*ResponseProcessor) Response ¶
func (r *ResponseProcessor) Response(res types.InvokerResponse)
Response is invoked whenever a response to a given function invocation is received.
Source Files
Click to show internal directories.
Click to hide internal directories.