parallel

Documentation

Index

• type Scheduler
  • func NewScheduler(maxC, maxQ int, ident string, ...) *Scheduler
  • func (p *Scheduler) AddWork(ctx context.Context, repo string, val *events.XRPCStreamEvent) 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(maxC, maxQ int, ident string, do func(context.Context, *events.XRPCStreamEvent) error) *Scheduler

func (*Scheduler) AddWork

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

func (*Scheduler) Shutdown

func (p *Scheduler) Shutdown()