test

Documentation

Index

• Variables
• func Consistently(timeout time.Duration, f func() bool) bool
• func Eventually(timeout time.Duration, f func() bool) bool
• func StartCpuSchedulingJitter()
• func WithContext(f func(ctx context.Context))
• func WithContextWithTimeout(d time.Duration, f func(ctx context.Context))
• type Latch
  • func NewLatch() *Latch
  • func (l *Latch) Resume(ctx context.Context)
  • func (l *Latch) ReturnWhenLatchIsPaused(ctx context.Context)
  • func (l *Latch) ReturnWhenLatchIsResumed(ctx context.Context)

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 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 Latch

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

func NewLatch

func NewLatch() *Latch

func (*Latch) Resume

func (l *Latch) Resume(ctx context.Context)

func (*Latch) ReturnWhenLatchIsPaused

func (l *Latch) ReturnWhenLatchIsPaused(ctx context.Context)

func (*Latch) ReturnWhenLatchIsResumed

func (l *Latch) ReturnWhenLatchIsResumed(ctx context.Context)