test

Documentation

Index

• Constants
• Variables
• func AssertCmpEqual(t *testing.T, expected interface{}, actual interface{}, ...) bool
• func Consistently(timeout time.Duration, f func() bool) bool
• func ConsistentlyVerify(timeout time.Duration, mocks ...mock.HasVerify) error
• func CreateTempDirForTest(t *testing.T) string
• func DebugPrintGoroutineStacks()
• func Eventually(timeout time.Duration, f func() bool) bool
• func EventuallyVerify(timeout time.Duration, mocks ...mock.HasVerify) error
• func RandomPort() int
• func RequireCmpEqual(t *testing.T, expected interface{}, actual interface{}, ...)
• func RequireNoUnexpectedErrors(f Fataler, errorTracker ErrorTracker)
• func RequireStatus(t *testing.T, status protocol.TransactionStatus, tx transactionStatuser, ...)
• func RequireSuccess(t *testing.T, tx transactionStatuser, msg string, args ...interface{})
• func StartCpuSchedulingJitter()
• func WithContext(f func(ctx context.Context))
• func WithContextWithTimeout(d time.Duration, f func(ctx context.Context))
• type ErrorTracker
• type Fataler

Constants

const CONSISTENTLY_ACCEPTANCE_TIMEOUT = 20 * time.Millisecond

const CONSISTENTLY_ADAPTER_TIMEOUT = 50 * time.Millisecond

const CONSISTENTLY_DOCKER_E2E_TIMEOUT = 500 * time.Millisecond

const CONSISTENTLY_LOCAL_E2E_TIMEOUT = 200 * time.Millisecond

const EVENTUALLY_ACCEPTANCE_TIMEOUT = 40 * time.Millisecond

const EVENTUALLY_ADAPTER_TIMEOUT = 100 * time.Millisecond

const EVENTUALLY_DOCKER_E2E_TIMEOUT = 1000 * time.Millisecond

const EVENTUALLY_LOCAL_E2E_TIMEOUT = 400 * time.Millisecond

Variables

var (
	MIN_REST_DURATION  = 1 * time.Millisecond
	MAX_REST_DURATION  = 5 * time.Millisecond
	MIN_BURST_DURATION = 1 * time.Millisecond
	MAX_BURST_DURATION = 10 * time.Millisecond
)

Functions

func AssertCmpEqual

func AssertCmpEqual(t *testing.T, expected interface{}, actual interface{}, msgAndArgs ...interface{}) bool

func Consistently

func Consistently(timeout time.Duration, f func() bool) bool

func ConsistentlyVerify

func ConsistentlyVerify(timeout time.Duration, mocks ...mock.HasVerify) error

func CreateTempDirForTest

func CreateTempDirForTest(t *testing.T) string

func DebugPrintGoroutineStacks

func DebugPrintGoroutineStacks()

func Eventually

func Eventually(timeout time.Duration, f func() bool) bool

func EventuallyVerify

func EventuallyVerify(timeout time.Duration, mocks ...mock.HasVerify) error

func RandomPort

func RandomPort() int

func RequireCmpEqual

func RequireCmpEqual(t *testing.T, expected interface{}, actual interface{}, msgAndArgs ...interface{})

func RequireNoUnexpectedErrors

func RequireNoUnexpectedErrors(f Fataler, errorTracker ErrorTracker)

func RequireStatus

func RequireStatus(t *testing.T, status protocol.TransactionStatus, tx transactionStatuser, msg string)

func RequireSuccess

func RequireSuccess(t *testing.T, tx transactionStatuser, msg string, args ...interface{})

func StartCpuSchedulingJitter

func StartCpuSchedulingJitter()

creates ongoing random bursts of cpu noise (all cores together) to make goroutine scheduling erratic in -count 100 flakiness tests

func WithContext

func WithContext(f func(ctx context.Context))

func WithContextWithTimeout

func WithContextWithTimeout(d time.Duration, f func(ctx context.Context))

Types

type ErrorTracker

type ErrorTracker interface {
	HasErrors() bool
	GetUnexpectedErrors() []string
}

type Fataler

type Fataler interface {
	Fatal(args ...interface{})
}