concurrency

Documentation

Index

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

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 {
	ConcurrencyStrategy() Strategy
	Tracker() progress.ServiceTracker
}

type Strategy

type Strategy int

const (
	DefaultStrategy Strategy = iota
	CPUCountStrategy
	OneAtATimeStrategy
)