processor

README

processor

Documentation

Index

• func OrDone[T any](ctx context.Context, works <-chan T) <-chan T
• type Processor
  • func NewProcessor(ctx context.Context) *Processor
  • func (p *Processor) DoWithParallel(works <-chan func(ctx context.Context) Result, numWorkers int, ...)
  • func (p *Processor) DoWithParallel2(works []func(ctx context.Context) Result, numWorkers int, ...)
  • func (p *Processor) DoWithRepeat(work func(ctx context.Context) Result, rate time.Duration, times int, ...)
  • func (p *Processor) DoWithRepeat2(work func(ctx context.Context) Result, rate time.Duration, until time.Time, ...)
• type Result

Functions

func OrDone

func OrDone[T any](ctx context.Context, works <-chan T) <-chan T

Types

type Processor

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

func NewProcessor

func NewProcessor(ctx context.Context) *Processor

func (*Processor) DoWithParallel

func (p *Processor) DoWithParallel(works <-chan func(ctx context.Context) Result, numWorkers int, handleResult func(result Result))

func (*Processor) DoWithParallel2

func (p *Processor) DoWithParallel2(works []func(ctx context.Context) Result, numWorkers int, handleResult func(result Result))

func (*Processor) DoWithRepeat

func (p *Processor) DoWithRepeat(work func(ctx context.Context) Result, rate time.Duration, times int, handleResult func(result Result))

func (*Processor) DoWithRepeat2

func (p *Processor) DoWithRepeat2(work func(ctx context.Context) Result, rate time.Duration, until time.Time, handleResult func(result Result))

type Result

type Result struct {
	Val any
	Err error
}