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{ … }