parallel

Documentation

Index

• func AddParallelChain[N, I, O any](opts flagutils.OptionSetProvider, c chain.Chain[I, O], a chain.Chain[O, N]) chain.Chain[I, N]
• type Options
  • func From(opts flagutils.OptionSetProvider) *Options
  • func New(n ...int) *Options
  • func (o *Options) Finalize(ctx context.Context, opts flagutils.OptionSet, v flagutils.FinalizationSet) error
  • func (o *Options) GetPool() processing.Processing
  • func (o *Options) Validate(ctx context.Context, opts flagutils.OptionSet, v flagutils.ValidationSet) error
  • func (o *Options) WithPoolProvider(p PoolProvider) *Options
• type PoolProvider

Functions

func AddParallelChain

func AddParallelChain[N, I, O any](opts flagutils.OptionSetProvider, c chain.Chain[I, O], a chain.Chain[O, N]) chain.Chain[I, N]

AddParallelChain evaluates the parallel Options (if present) to decide whether chain a should be executed parallel or just added to chain c. This helper can be used, for example, by output implementations to organize their processing chains.

Types

type Options

type Options struct {
	flagutils.SimpleOption[int, *Options]
	// contains filtered or unexported fields
}

func From

func From(opts flagutils.OptionSetProvider) *Options

func New

func New(n ...int) *Options

func (*Options) Finalize

func (o *Options) Finalize(ctx context.Context, opts flagutils.OptionSet, v flagutils.FinalizationSet) error

func (*Options) GetPool

func (o *Options) GetPool() processing.Processing

func (*Options) Validate

func (o *Options) Validate(ctx context.Context, opts flagutils.OptionSet, v flagutils.ValidationSet) error

func (*Options) WithPoolProvider

func (o *Options) WithPoolProvider(p PoolProvider) *Options

type PoolProvider

type PoolProvider func(ctx context.Context, n int) processing.Processing