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       *pgxpool.Pool
	EmailSvc services.Email
}