safe_go

Nov 12, 2024

Changes in this version

+ func Go(wg *sync.WaitGroup, ignoreRecover bool, ...)

type Runner

+ func (r *Runner) Report() string

Nov 8, 2024

Changes in this version

+ func AntsInit()

+ func AntsRunner(fns ...util.Func) error

+ func DryRun(fns ...util.Func) error

+ func Run(fns ...util.Func) error

+ func TaskConverter(fns ...util.Fn) []util.Func

+ type Option func(r *Runner)

+ func WithContext(context context.Context) Option

+ func WithDeadlineCancel(deadline time.Time) Option

+ func WithErrCancel() Option

+ func WithErrDryRun() Option

+ func WithLimit(limit int) Option

+ func WithPanicRecover() Option

+ func WithProgressReport(bar chan<- int) Option

+ func WithTimeoutCancel(timeout time.Duration) Option

+ type Runner struct

+ func NewRunner(tasks []util.Func, options ...Option) *Runner

+ func (r *Runner) Error() string

+ func (r *Runner) Go() *Runner