parallelize

Documentation

Index

• Constants
• type Parallelizer
  • func NewParallelizer(p int) Parallelizer
  • func (p Parallelizer) Until(ctx context.Context, pieces int, doWorkPiece workqueue.DoWorkPieceFunc)

Constants

const DefaultParallelism int = 16

DefaultParallelism is the default parallelism used in scheduler.

Types

type Parallelizer

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

Parallelizer holds the parallelism for scheduler.

func NewParallelizer

func NewParallelizer(p int) Parallelizer

NewParallelizer returns an object holding the parallelism.

func (Parallelizer) Until

func (p Parallelizer) Until(ctx context.Context, pieces int, doWorkPiece workqueue.DoWorkPieceFunc)

Until is a wrapper around workqueue.ParallelizeUntil to use in scheduling algorithms. A given operation will be a label that is recorded in the goroutine metric.