Function NewAsyncMessageHandler

pkg/dequeuer/async_handler.go:58–67

(config AsyncMessageHandlerConfig, awsClient *awslib.Client, eventHandler RequestEventHandler, logger *zap.SugaredLogger)

}

func NewAsyncMessageHandler(config AsyncMessageHandlerConfig, awsClient *awslib.Client, eventHandler RequestEventHandler, logger *zap.SugaredLogger) *AsyncMessageHandler {
	return &AsyncMessageHandler{
		config:       config,
		aws:          awsClient,
		log:          logger,
		storagePath:  async.StoragePath(config.ClusterUID, config.APIName),
		httpClient:   &http.Client{},
		eventHandler: eventHandler,
	}
}

func (h *AsyncMessageHandler) Handle(message *sqs.Message) error {
	if message == nil {