worker

Documentation

Overview

Package worker provides a worker that processes S3 event notifications.

Index

• type Worker
  • func New(tel component.TelemetrySettings, cfg aws.Config, unmarshaler event.Unmarshaler, ...) *Worker
  • func (w *Worker) ProcessMessage(ctx context.Context, msg types.Message, queueURL string, deferThis func())

Types

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

Worker processes S3 event notifications. It is responsible for processing messages from the SQS queue and sending them to the next consumer. It also handles deleting messages from the SQS queue after they have been processed. It is designed to be used in a worker pool.

func New

func New(tel component.TelemetrySettings, cfg aws.Config, unmarshaler event.Unmarshaler, directory string) *Worker

New creates a new Worker

func (*Worker) ProcessMessage

func (w *Worker) ProcessMessage(ctx context.Context, msg types.Message, queueURL string, deferThis func())

ProcessMessage processes a message from the SQS queue TODO add metric for number of messages processed / deleted / errors, events processed, etc.