Versions in this module Expand all Collapse all v2 v2.0.1 Feb 24, 2023 Changes in this version + type Butcher interface + Run func(context.Context) error + func NewButcher(executor Executor[T], opts ...Option) (Butcher, error) + type Executor interface + GenerateJob func(ctx context.Context, jobCh chan<- T) error + Task func(ctx context.Context, job T) error + type OnFinishWatcher interface + OnFinish func(ctx context.Context, job T, err error) + type Option func(b *butcherCfg) error + func BufferSize(size int) Option + func InterruptSignal(signals ...os.Signal) Option + func MaxWorker(count int) Option + func RateLimit(tasksPerSecond float64) Option + func RetryOnError(maxTimes int) Option + func TaskTimeout(timeout time.Duration) Option Other modules containing this package github.com/KawashiroNitori/butcher