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 RequireDoesNotContainNil(t *testing.T, obj interface{}) bool
• 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 ControlledRand
  • func NewControlledRand(t testLogger) *ControlledRand
  • func (sr ControlledRand) Float32() float32
  • func (sr ControlledRand) Float64() float64
  • func (sr ControlledRand) Int() int
  • func (sr ControlledRand) Int31() int32
  • func (sr ControlledRand) Int31n(n int32) int32
  • func (sr ControlledRand) Int63() int64
  • func (sr ControlledRand) Int63n(n int64) int64
  • func (sr ControlledRand) Intn(n int) int
  • func (sr ControlledRand) Perm(n int) []int
  • func (sr ControlledRand) Read(p []byte) (n int, err error)
  • func (sr ControlledRand) Seed(seed int64)
  • func (sr ControlledRand) Shuffle(n int, swap func(i, j int))
  • func (sr ControlledRand) Uint32() uint32
  • func (sr ControlledRand) Uint64() uint64
• 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 RequireDoesNotContainNil

func RequireDoesNotContainNil(t *testing.T, obj interface{}) bool

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 ControlledRand

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

tests should use this random object when generating random values

func NewControlledRand

func NewControlledRand(t testLogger) *ControlledRand

func (ControlledRand) Float32

func (sr ControlledRand) Float32() float32

func (ControlledRand) Float64

func (sr ControlledRand) Float64() float64

func (ControlledRand) Int

func (sr ControlledRand) Int() int

func (ControlledRand) Int31

func (sr ControlledRand) Int31() int32

func (ControlledRand) Int31n

func (sr ControlledRand) Int31n(n int32) int32

func (ControlledRand) Int63

func (sr ControlledRand) Int63() int64

func (ControlledRand) Int63n

func (sr ControlledRand) Int63n(n int64) int64

func (ControlledRand) Intn

func (sr ControlledRand) Intn(n int) int

func (ControlledRand) Perm

func (sr ControlledRand) Perm(n int) []int

func (ControlledRand) Read

func (sr ControlledRand) Read(p []byte) (n int, err error)

func (ControlledRand) Seed

func (sr ControlledRand) Seed(seed int64)

func (ControlledRand) Shuffle

func (sr ControlledRand) Shuffle(n int, swap func(i, j int))

func (ControlledRand) Uint32

func (sr ControlledRand) Uint32() uint32

func (ControlledRand) Uint64

func (sr ControlledRand) Uint64() uint64

type ErrorTracker

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

type Fataler

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