workers

Documentation

Index

• func DoParallel[T any](n int, fns []func() T) []T
• func DoParallelErrGroup[T any](ctx context.Context, n int, fns []func(ctx context.Context) (T, error)) ([]T, error)
• type SleepWorker
  • func NewSleepWorker(fn func() bool, cfg SleepWorkerConfig) *SleepWorker
  • func (w *SleepWorker) Start()
  • func (w *SleepWorker) Stop()
• type SleepWorkerConfig
• type WorkerId

Functions

func DoParallel

func DoParallel[T any](n int, fns []func() T) []T

func DoParallelErrGroup

func DoParallelErrGroup[T any](ctx context.Context, n int, fns []func(ctx context.Context) (T, error)) ([]T, error)

Types

type SleepWorker

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

func NewSleepWorker

func NewSleepWorker(fn func() bool, cfg SleepWorkerConfig) *SleepWorker

func (*SleepWorker) Start

func (w *SleepWorker) Start()

func (*SleepWorker) Stop

func (w *SleepWorker) Stop()

type SleepWorkerConfig

type SleepWorkerConfig struct {
	Interval time.Duration
}

type WorkerId

type WorkerId int