processor

README

processor

Documentation

Index

• func OrDone[T any](ctx context.Context, works <-chan T) <-chan T
• func SpeedLimit(ctx context.Context, works <-chan Work, speedLimit time.Duration) <-chan Work
• type Processor
  • func NewProcessor(ctx context.Context) *Processor
  • func (p *Processor) DoWithParallel(works <-chan Work, numWorkers int) Results
  • func (p *Processor) DoWithRate(works <-chan Work, rate time.Duration) Results
  • func (p *Processor) DoWithRepeat(work Work, rate time.Duration, until time.Time) Results
• type Result
  • func NewResult[R any](val R, err error) Result
• type Results
  • func CollectResults(ctx context.Context, rs ...Results) Results
  • func (rs Results) HandleResults(f func(result Result))
• type Work

Functions

func OrDone

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

func SpeedLimit

func SpeedLimit(ctx context.Context, works <-chan Work, speedLimit time.Duration) <-chan Work

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 Work, numWorkers int) Results

func (*Processor) DoWithRate

func (p *Processor) DoWithRate(works <-chan Work, rate time.Duration) Results

func (*Processor) DoWithRepeat

func (p *Processor) DoWithRepeat(work Work, rate time.Duration, until time.Time) Results

type Result

type Result struct {
	Val any
	Err error
}

func NewResult

func NewResult[R any](val R, err error) Result

type Results

type Results <-chan Result

func CollectResults

func CollectResults(ctx context.Context, rs ...Results) Results

func (Results) HandleResults

func (rs Results) HandleResults(f func(result Result))

type Work

type Work struct {
	Do func(ctx context.Context) Result
}