testutil

May 15, 2024

Changes in this version

+ type Resetable interface

+ Reset func()

+ type Tester struct

+ func Test[R any](t *testing.T) *Tester[R]

+ func (t *Tester[R]) AssertFailure(expectedAttempts int, expectedExecutions int, expectedError error, ...)

+ func (t *Tester[R]) AssertSuccess(expectedAttempts int, expectedExecutions int, expectedResult R, then ...func())

+ func (t *Tester[R]) AssertSuccessError(expectedAttempts int, expectedExecutions int, expectedError error, ...)

+ func (t *Tester[R]) Context(fn func() context.Context) *Tester[R]

+ func (t *Tester[R]) Get(when WhenGet[R]) *Tester[R]

+ func (t *Tester[R]) Reset(stats ...Resetable) *Tester[R]

+ func (t *Tester[R]) Run(when WhenRun[R]) *Tester[R]

+ func (t *Tester[R]) Setup(fn func()) *Tester[R]

+ func (t *Tester[R]) With(policies ...failsafe.Policy[R]) *Tester[R]

+ func (t *Tester[R]) WithExecutor(executor failsafe.Executor[R]) *Tester[R]

Apr 8, 2024

Changes in this version

+ func MockFlakyServer(failTimes int, responseCode int, retryAfterDelay time.Duration, ...) *httptest.Server

+ func PrepareTest[R any](t *testing.T, given Given, executor failsafe.Executor[R], expectedAttempts int, ...) (executorFn func() failsafe.Executor[R], assertResult func(R, error))

+ func TestGetSuccessError[R any](t *testing.T, given Given, executor failsafe.Executor[R], when WhenGet[R], ...)

Mar 4, 2024

Changes in this version

+ func MockDelayedResponse(statusCode int, body string, delay time.Duration) *httptest.Server

+ func MockResponse(statusCode int, body string) *httptest.Server

+ func TestRequestFailureError(t *testing.T, url string, executor failsafe.Executor[*http.Response], ...)

+ func TestRequestFailureResult(t *testing.T, url string, executor failsafe.Executor[*http.Response], ...)

+ func TestRequestSuccess(t *testing.T, url string, executor failsafe.Executor[*http.Response], ...)

Feb 26, 2024

Changes in this version

type TestExecution

+ TheHedges int

+ TheRetries int

+ func (e TestExecution[R]) Hedges() int

+ func (e TestExecution[R]) IsHedge() bool

+ func (e TestExecution[R]) Retries() int

Nov 28, 2023

Changes in this version

type TestExecution

+ TheAttempts int

Nov 5, 2023

Changes in this version

type CompositeError

+ func NewCompositeError(cause error) *CompositeError

Sep 25, 2023

Changes in this version

+ func SetupWithContextSleep(sleepTime time.Duration) func() context.Context

type TestExecution

+ func (s TestExecution[R]) Context() context.Context

Sep 19, 2023

Changes in this version

+ var ErrConnecting = errors.New("connection error")

+ var ErrInvalidArgument = errors.New("invalid argument")

+ var ErrInvalidState = errors.New("invalid state")

+ var ErrTimeout = errors.New("timeout error")

+ var GetFalseFn = func() (bool, error)

+ var GetTrueFn = func() (bool, error)

+ var NoopFn = func() error

+ func AssertDuration(t *testing.T, expectedDuration int, actualDuration time.Duration)

+ func ErrorNTimesThenError(err error, errorTimes int, finalError error) func(exec failsafe.Execution[R]) (R, error)

+ func ErrorNTimesThenPanic(err error, errorTimes int, panicValue any) func(exec failsafe.Execution[R]) (R, error)

+ func ErrorNTimesThenReturn(err error, errorTimes int, results ...R) (fn func(exec failsafe.Execution[R]) (R, error), resetFn func())

+ func GetFn(result R, err error) func() (R, error)

+ func GetType(myvar interface{}) string

+ func GetWithExecutionFn(result R, err error) func(exec failsafe.Execution[R]) (R, error)

+ func MillisToNanos(millis int) int64

+ func RunFn(err error) func() error

+ func TestGetFailure(t *testing.T, given Given, executor failsafe.Executor[R], when WhenGet[R], ...)

+ func TestGetSuccess(t *testing.T, given Given, executor failsafe.Executor[R], when WhenGet[R], ...)

+ func TestRunFailure(t *testing.T, given Given, executor failsafe.Executor[R], when WhenRun[R], ...)

+ func TestRunSuccess(t *testing.T, given Given, executor failsafe.Executor[R], when WhenRun[R], ...)

+ func Timed(fn func()) time.Duration

+ func WaitAndAssertCanceled(t *testing.T, waitDuration time.Duration, exec failsafe.Execution[R])

+ type CompositeError struct

+ Cause error

+ func (ce *CompositeError) Error() string

+ func (ce *CompositeError) Is(err error) bool

+ func (ce *CompositeError) Unwrap() error

+ type Given func() context.Context

+ type TestClock struct

+ CurrentTime int64

+ func (t *TestClock) CurrentUnixNano() int64

+ type TestExecution struct

+ TheLastResult R

+ func (s TestExecution[R]) AttemptStartTime() time.Time

+ func (s TestExecution[R]) Attempts() int

+ func (s TestExecution[R]) Canceled() <-chan any

+ func (s TestExecution[R]) ElapsedAttemptTime() time.Duration

+ func (s TestExecution[R]) ElapsedTime() time.Duration

+ func (s TestExecution[R]) Executions() int

+ func (s TestExecution[R]) IsCanceled() bool

+ func (s TestExecution[R]) IsFirstAttempt() bool

+ func (s TestExecution[R]) IsRetry() bool

+ func (s TestExecution[R]) LastError() error

+ func (s TestExecution[R]) LastResult() R

+ func (s TestExecution[R]) StartTime() time.Time

+ type TestStopwatch struct

+ CurrentTime int64

+ func (t *TestStopwatch) ElapsedTime() time.Duration

+ func (t *TestStopwatch) Reset()

+ type Waiter struct

+ func NewWaiter() *Waiter

+ func (w *Waiter) AssertEqual(t *testing.T, expected, actual interface{}, msgAndArgs ...interface{}) bool

+ func (w *Waiter) Await(expectedResumes int)

+ func (w *Waiter) AwaitWithTimeout(expectedResumes int, timeout time.Duration)

+ func (w *Waiter) Resume()

+ type WhenGet func(execution failsafe.Execution[R]) (R, error)

+ type WhenRun func(execution failsafe.Execution[R]) error