plumber

Documentation

Index

• func ContextWithConfig(ctx context.Context, config Config) context.Context
• func LaunchAndWait(ctx context.Context, rlatorNames []string, fns []Launchable, ...) (outputs []interface{})
• func OrDone[T any](ctx context.Context, c chan T) chan T
• func Parallelize[IT any, OT any](ctx context.Context, rlatorName string, fn func(context.Context, IT) OT, ...) (outputs []OT)
• func Regulated[IT any, OT any](ctx context.Context, rlatorName string, fn func(context.Context, IT) OT, ...) (output OT)
• func Retype[OT any](inputs []interface{}) (outputs []OT)
• func Untype[IT any](inputs []IT) (outputs []interface{})
• type Config
  • func ConfigFromContext(ctx context.Context) (config Config, ok bool)
• type Launchable
• type Reducer
  • func NewReducer(limit int, maxSleep time.Duration) Reducer
  • func NewUsReducer(limit int, maxSleep time.Duration) Reducer
• type ReducerWork

Functions

func ContextWithConfig

func ContextWithConfig(ctx context.Context, config Config) context.Context

func LaunchAndWait

func LaunchAndWait(
	ctx context.Context,
	rlatorNames []string,
	fns []Launchable,
	inputs []interface{},
) (outputs []interface{})

func OrDone

func OrDone[T any](ctx context.Context, c chan T) chan T

func Parallelize

func Parallelize[IT any, OT any](
	ctx context.Context,
	rlatorName string,
	fn func(context.Context, IT) OT,
	inputs ...IT,
) (outputs []OT)

func Regulated

func Regulated[IT any, OT any](
	ctx context.Context,
	rlatorName string,
	fn func(context.Context, IT) OT,
	input IT,
) (output OT)

func Retype

func Retype[OT any](inputs []interface{}) (outputs []OT)

func Untype

func Untype[IT any](inputs []IT) (outputs []interface{})

Types

type Config

type Config struct {
	PlizerEnabled  bool            // false globally disable parallelization
	RglatorsByName map[string]uint // number of parallelizable functions by name
	// contains filtered or unexported fields
}

func ConfigFromContext

func ConfigFromContext(ctx context.Context) (config Config, ok bool)

type Launchable

type Launchable func(ctx context.Context, input interface{}) (output interface{})

type Reducer

type Reducer interface {
	SetDbgOut(w io.Writer)
	Launch(label string, work ReducerWork) error
	Close() error
}

func NewReducer

func NewReducer(limit int, maxSleep time.Duration) Reducer

func NewUsReducer

func NewUsReducer(limit int, maxSleep time.Duration) Reducer

type ReducerWork

type ReducerWork func() error