parallelizer

package

v0.10.1 Latest Latest Go to latest Published: Apr 28, 2024 License: MIT Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package parallelizer features some utilities to help run tasks in parallel.

View Source

const (
	// The default number of workers.
	DefaultNumOfWorkers = 4
)

This section is empty.

This section is empty.

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

ErrorFlag is a flag for indicating whether an error has occurred when running tasks in parallel with the parallelizer.

func NewErrorFlag() *ErrorFlag

NewErrorFlag returns an error flag.

func (f *ErrorFlag) Lower() error

Lower lowers the error flag and returns the error that was used to raise the flag; it returns nil if the flag has not been raised.

func (f *ErrorFlag) Raise(err error)

Raise raises the error flag with an error; if the flag has been raised, it will return immediately.

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

Parallelizer helps run tasks in parallel.

func NewParallelizer(workers int) *Parallerlizer

NewParallelizer returns a Parallelizer for running tasks in parallel.

func (p *Parallerlizer) ParallelizeUntil(ctx context.Context, pieces int, doWork workqueue.DoWorkPieceFunc, operation string)

ParallelizeUntil wraps workqueue.ParallelizeUntil for running tasks in parallel.