parallel

Documentation

Overview

Package parallel provides a parallel scheduler that will run work on a fixed number of workers. Events for the same repository will be processed sequentially, but events for different repositories can be processed concurrently.

Index

• type Scheduler
  • func NewScheduler(numWorkers int, ident string, logger *slog.Logger, ...) *Scheduler
  • func (p *Scheduler) AddWork(ctx context.Context, repo string, val *models.Event) error
  • func (p *Scheduler) Shutdown()

Types

type Scheduler

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

Scheduler is a parallel scheduler that will run work on a fixed number of workers

func NewScheduler

func NewScheduler(numWorkers int, ident string, logger *slog.Logger, handleEvent func(context.Context, *models.Event) error) *Scheduler

NewScheduler creates a new parallel scheduler with the given number of workers

func (*Scheduler) AddWork

func (p *Scheduler) AddWork(ctx context.Context, repo string, val *models.Event) error

AddWork adds work to the scheduler

func (*Scheduler) Shutdown

func (p *Scheduler) Shutdown()

Shutdown shuts down the scheduler, waiting for all workers to finish their current work The existing work queue will be processed, but no new work will be accepted