concurrency

package
v1.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 25, 2023 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Adapt

func Adapt[T any, S any](items []T, ctx Context, adapt func(T) (*S, error)) []S

func AdaptWithState

func AdaptWithState[T any, S any](items []T, currentState *state.State, ctx Context, adapt func(T, *state.State) (*S, error)) []S

Types

type Context

type Context interface {
	Debug(format string, args ...interface{})
	ConcurrencyStrategy() Strategy
	Tracker() progress.ServiceTracker
}

type Strategy

type Strategy int
const (
	DefaultStrategy Strategy = iota
	CPUCountStrategy
	OneAtATimeStrategy
)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL