kubernetes/pkg/util/goroutinemap/goroutinemap_test.go

const testTimeout

const initialOperationWaitTimeShort

const initialOperationWaitTimeLong

func Test_NewGoRoutineMap_Positive_SingleOp(t *testing.T) {}

func Test_NewGoRoutineMap_Positive_TwoOps(t *testing.T) {}

func Test_NewGoRoutineMap_Positive_SingleOpWithExpBackoff(t *testing.T) {}

func Test_NewGoRoutineMap_Positive_SecondOpAfterFirstCompletes(t *testing.T) {}

func Test_NewGoRoutineMap_Positive_SecondOpAfterFirstCompletesWithExpBackoff(t *testing.T) {}

func Test_NewGoRoutineMap_Positive_SecondOpAfterFirstPanics(t *testing.T) {}

func Test_NewGoRoutineMap_Positive_SecondOpAfterFirstPanicsWithExpBackoff(t *testing.T) {}

func Test_NewGoRoutineMap_Negative_SecondOpBeforeFirstCompletes(t *testing.T) {}

func Test_NewGoRoutineMap_Negative_SecondOpBeforeFirstCompletesWithExpBackoff(t *testing.T) {}

func Test_NewGoRoutineMap_Positive_ThirdOpAfterFirstCompletes(t *testing.T) {}

func Test_NewGoRoutineMap_Positive_ThirdOpAfterFirstCompletesWithExpBackoff(t *testing.T) {}

func Test_NewGoRoutineMap_Positive_WaitEmpty(t *testing.T) {}

func Test_NewGoRoutineMap_Positive_WaitEmptyWithExpBackoff(t *testing.T) {}

func Test_NewGoRoutineMap_Positive_Wait(t *testing.T) {}

func Test_NewGoRoutineMap_Positive_WaitWithExpBackoff(t *testing.T) {}

func Test_NewGoRoutineMap_WaitForCompletionWithExpBackoff(t *testing.T) {}

func generateCallbackFunc(done chan<- interface{}

func generateErrorFunc(done <-chan interface{}

func generateWaitFunc(done <-chan interface{}

func generatePanicFunc() func() error {}

func generateNoopFunc() func() error {}

func retryWithExponentialBackOff(initialDuration time.Duration, fn wait.ConditionFunc) error {}

func waitChannelWithTimeout(ch <-chan interface{}