run

Oct 16, 2025

Changes in this version

+ type FuncRunner interface

+ Run func(runFunc Func) error

+ type FuncRunnerFunc func(runFunc Func) error

+ func (b FuncRunnerFunc) Run(runFunc Func) error

Aug 5, 2025

Changes in this version

+ type HasCaptureException interface

+ CaptureException func(exception error, hint *sentry.EventHint, scope sentry.EventModifier) *sentry.EventID

May 1, 2025

Changes in this version

+ func ContextWithSig(ctx context.Context) context.Context

Mar 11, 2024

Changes in this version

+ var DefaultWaiter = NewWaiter()

type Backoff

+ Factor float64

type Func

+ func RetryWaiter(backoff Backoff, waiter Waiter, fn Func) Func

+ type Waiter interface

+ Wait func(ctx context.Context, wait time.Duration) error

+ func NewWaiter() Waiter

+ type WaiterFunc func(ctx context.Context, wait time.Duration) error

+ func (w WaiterFunc) Wait(ctx context.Context, wait time.Duration) error

Oct 4, 2023

Changes in this version

+ type BackgroundRunner interface

+ Run func(runFunc Func) error

+ func NewBackgroundRunner(ctx context.Context) BackgroundRunner

Aug 4, 2023

Changes in this version

type Backoff

+ IsRetryAble func(error) bool

Jul 2, 2023

Changes in this version

+ func All(ctx context.Context, funcs ...Func) error

+ func CancelOnFirstError(ctx context.Context, funcs ...Func) error

+ func CancelOnFirstErrorWait(ctx context.Context, funcs ...Func) error

+ func CancelOnFirstFinish(ctx context.Context, funcs ...Func) error

+ func CancelOnFirstFinishWait(ctx context.Context, funcs ...Func) error

+ func NewErrorList(errors ...error) error

+ func NewErrorListByChan(errors <-chan error) error

+ func NewMetrics(registerer prometheus.Registerer, namespace string, subsystem string, fn Func) func(ctx context.Context) error

+ func Run(ctx context.Context, funcs ...Func) <-chan error

+ func Sequential(ctx context.Context, funcs ...Func) (err error)

+ func SkipErrors(fn Func) func(context.Context) error

+ func SkipErrorsAndReport(fn Func, hasCaptureErrorAndWait HasCaptureErrorAndWait, tags map[string]string) func(context.Context) error

+ type AddFire interface

+ Add func() Fire

+ type Backoff struct

+ Delay time.Duration

+ Retries int

+ type ConcurrentRunner interface

+ Add func(ctx context.Context, fn Func)

+ Run func(ctx context.Context) error

+ func NewConcurrentRunner(maxConcurrent int) ConcurrentRunner

+ type Done interface

+ Done func() <-chan struct{}

+ type ErrorList []error

+ func (e ErrorList) Error() string

+ func (e ErrorList) Unwrap() []error

+ type Fire interface

+ Fire func()

+ type Func func(context.Context) error

+ func CatchPanic(fn Func) Func

+ func Delayed(fn Func, duration time.Duration) Func

+ func LogErrors(fn Func) Func

+ func Retry(backoff Backoff, fn Func) Func

+ func Triggered(fn Func, trigger <-chan struct{}) Func

+ func (r Func) Run(ctx context.Context) error

+ type HasCaptureErrorAndWait interface

+ CaptureErrorAndWait func(err error, tags map[string]string, interfaces ...raven.Interface) string

+ type MultiTrigger interface

+ func NewMultiTrigger() MultiTrigger

+ type ParallelSkipper interface

+ SkipParallel func(action Func) Func

+ func NewParallelSkipper() ParallelSkipper

+ type Runnable interface

+ Run func(ctx context.Context) error

+ type Trigger interface

+ func NewTrigger() Trigger