workers

Documentation

Index

• func SetupWorkers(deps WorkerDependencies) (*river.Workers, error)
• type EmailJobWorker
  • func (w *EmailJobWorker) Work(ctx context.Context, job *river.Job[jobs.EmailJobArgs]) error
• type WorkerDependencies

Functions

func SetupWorkers

func SetupWorkers(deps WorkerDependencies) (*river.Workers, error)

Types

type EmailJobWorker

type EmailJobWorker struct {
	river.WorkerDefaults[jobs.EmailJobArgs]
	// contains filtered or unexported fields
}

func (*EmailJobWorker) Work

func (w *EmailJobWorker) Work(ctx context.Context, job *river.Job[jobs.EmailJobArgs]) error

type WorkerDependencies

type WorkerDependencies struct {
	DB      *database.Queries
	Emailer awsses.AwsSimpleEmailService
	Tracer  telemetry.Tracer
}