safe_go

Documentation

Index

• func AntsInit()
• func AntsRunner(fns ...util.Func) error
• func DryRun(fns ...util.Func) error
• func Go(wg *sync.WaitGroup, ignoreRecover bool, ...)
• func Run(fns ...util.Func) error
• func TaskConverter(fns ...util.Fn) []util.Func
• type Option
  • 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
  • func NewRunner(tasks []util.Func, options ...Option) *Runner
  • func (r *Runner) Error() string
  • func (r *Runner) Go() *Runner
  • func (r *Runner) Report() string

Functions

func AntsInit

func AntsInit()

func AntsRunner

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

func DryRun

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

func Go

func Go(
	wg *sync.WaitGroup,
	ignoreRecover bool,
	doRecoverStack func(recoverTime time.Time, debugStack []byte),
	handler func(),
	catchHandler func(v ...any),
)

func Run

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

func TaskConverter

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

Types

type Option

type Option func(r *Runner)

func WithContext

func WithContext(context context.Context) Option

func WithDeadlineCancel

func WithDeadlineCancel(deadline time.Time) Option

func WithErrCancel

func WithErrCancel() Option

func WithErrDryRun

func WithErrDryRun() Option

func WithLimit

func WithLimit(limit int) Option

func WithPanicRecover

func WithPanicRecover() Option

func WithProgressReport

func WithProgressReport(bar chan<- int) Option

func WithTimeoutCancel

func WithTimeoutCancel(timeout time.Duration) Option

type Runner

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

Runner

• Runner
• 1. context injection
• 2. goroutine limit control
• 3. error catch mode:
• (1). one error cancel all: return error
• (2). any error dry run: collect errors, return mergedError
• (3). any panic recover: collect errors, return mergedError, collect stacktrace,
• 4. timeout control
• 5. progress report

func NewRunner

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

func (*Runner) Error

func (r *Runner) Error() string

func (*Runner) Go

func (r *Runner) Go() *Runner

func (*Runner) Report

func (r *Runner) Report() string