test

Documentation

Index

• Variables
• func Consistently(timeout time.Duration, f func() bool) bool
• func Eventually(timeout time.Duration, f func() bool) bool
• func FailIfNotDoneByTimeout(t *testing.T, waitGroup *sync.WaitGroup, timeout time.Duration, format string, ...)
• func NameHashPrefix(tb testing.TB, idLen int) string
• func StartCpuSchedulingJitter()
• func WithContext(f func(ctx context.Context))
• func WithContextWithTimeout(t *testing.T, d time.Duration, f func(ctx context.Context))
• type Latch
  • func NewLatch(logger interfaces.Logger) *Latch
  • func (l *Latch) Resume(ctx context.Context, memberId primitives.MemberId)
  • func (l *Latch) ReturnWhenLatchIsPaused(ctx context.Context, memberId primitives.MemberId)
  • func (l *Latch) WaitOnPauseThenWaitOnResume(ctx context.Context, memberId primitives.MemberId)

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 Consistently

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

func Eventually

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

func FailIfNotDoneByTimeout

func FailIfNotDoneByTimeout(t *testing.T, waitGroup *sync.WaitGroup, timeout time.Duration, format string, args ...interface{})

func NameHashPrefix

func NameHashPrefix(tb testing.TB, idLen int) string

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(t *testing.T, d time.Duration, f func(ctx context.Context))

Types

type Latch

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

func NewLatch

func NewLatch(logger interfaces.Logger) *Latch

func (*Latch) Resume

func (l *Latch) Resume(ctx context.Context, memberId primitives.MemberId)

func (*Latch) ReturnWhenLatchIsPaused

func (l *Latch) ReturnWhenLatchIsPaused(ctx context.Context, memberId primitives.MemberId)

func (*Latch) WaitOnPauseThenWaitOnResume

func (l *Latch) WaitOnPauseThenWaitOnResume(ctx context.Context, memberId primitives.MemberId)