Method Run

internal/test/test.go:38–72

(fn func(t testing.TB))

}

func (f *flaky) Run(fn func(t testing.TB)) {
	var last error

	for attempt := 1; attempt <= f.o.MaxAttempts; attempt++ {
		r := &recorder{
			TB:    f.t,
			fail:  func(s string) { last = errors.New(s) },
			fatal: func(s string) { last = errors.New(s) },
		}

		func() {
			failCodes := []int{RecorderFailNow, RecorderFatalf, RecorderFatal}
			defer func() {
				if rec := recover(); rec != nil {
					if code, ok := rec.(int); ok && !slices.Contains(failCodes, code) {
						panic(rec)
					}
				}
			}()

			fn(r)
		}()

		if !r.Failed() {
			return
		}

		if attempt < f.o.MaxAttempts {
			backoff := f.o.InitialBackoff * time.Duration(1<<uint(attempt-1))
			time.Sleep(applyJitter(backoff, f.o.Jitter))
		}
	}

	f.t.Fatalf("[%s] test failed after %d attempts: %v", f.t.Name(), f.o.MaxAttempts, last)
}

func applyJitter(d time.Duration, jitter float64) time.Duration {
	if jitter == 0 {