workerpool

Documentation

Index

• type JobProcessor
• type Pool
  • func (p Pool[TJob]) Start(ctx context.Context, numWorkers int, processor JobProcessor[TJob], jobs []TJob) []error
  • func (p Pool[TJob]) StartWorker(ctx context.Context, processor JobProcessor[TJob], id int, wg *sync.WaitGroup, ...)

Types

type JobProcessor

type JobProcessor[TJob any] interface {
	Process(
		ctx context.Context,
		job TJob) error
}

JobProcessor defines the contract for processing a single job within a workflow.

type Pool

type Pool[TJob any] struct{}

Generic pool type, can work with any job type.

func (Pool[TJob]) Start

func (p Pool[TJob]) Start(ctx context.Context, numWorkers int, processor JobProcessor[TJob], jobs []TJob) []error

func (Pool[TJob]) StartWorker

func (p Pool[TJob]) StartWorker(
	ctx context.Context,
	processor JobProcessor[TJob],
	id int,
	wg *sync.WaitGroup,
	jobs <-chan TJob,
	errChan chan<- error)