kubernetes/pkg/volume/util/nestedpendingoperations/nestedpendingoperations_test.go

const testTimeout …

const initialOperationWaitTimeShort …

const initialOperationWaitTimeLong …

func Test_NestedPendingOperations_Positive_SingleOp(t *testing.T) { … }

func Test_NestedPendingOperations_Positive_TwoOps(t *testing.T) { … }

func Test_NestedPendingOperations_Positive_TwoSubOps(t *testing.T) { … }

func Test_NestedPendingOperations_Positive_SingleOpWithExpBackoff(t *testing.T) { … }

func Test_NestedPendingOperations_Positive_SecondOpAfterFirstCompletes(t *testing.T) { … }

func Test_NestedPendingOperations_Positive_SecondOpAfterFirstCompletesWithExpBackoff(t *testing.T) { … }

func Test_NestedPendingOperations_Positive_SecondOpAfterFirstPanics(t *testing.T) { … }

func Test_NestedPendingOperations_Positive_SecondOpAfterFirstPanicsWithExpBackoff(t *testing.T) { … }

func Test_NestedPendingOperations_Negative_SecondOpBeforeFirstCompletes(t *testing.T) { … }

func Test_NestedPendingOperations_Negative_SecondThirdOpWithDifferentNames(t *testing.T) { … }

func Test_NestedPendingOperations_Negative_SecondSubOpBeforeFirstCompletes2(t *testing.T) { … }

func Test_NestedPendingOperations_Negative_SecondSubOpBeforeFirstCompletes(t *testing.T) { … }

func Test_NestedPendingOperations_Negative_SecondOpBeforeFirstCompletesWithExpBackoff(t *testing.T) { … }

func Test_NestedPendingOperations_Positive_ThirdOpAfterFirstCompletes(t *testing.T) { … }

func Test_NestedPendingOperations_Positive_ThirdOpAfterFirstCompletesWithExpBackoff(t *testing.T) { … }

func Test_NestedPendingOperations_Positive_WaitEmpty(t *testing.T) { … }

func Test_NestedPendingOperations_Positive_WaitEmptyWithExpBackoff(t *testing.T) { … }

func Test_NestedPendingOperations_Positive_Wait(t *testing.T) { … }

func Test_NestedPendingOperations_Positive_WaitWithExpBackoff(t *testing.T) { … }

func Test_NestedPendingOperations_SecondOpBeforeFirstCompletes(t *testing.T) { … }

func Test_NestedPendingOperations_Positive_Issue_88355(t *testing.T) { … }

// testConcurrentOperationsPositive passes if the two operations keyed by the
// provided parameters are executed in parallel, and fails otherwise.
func testConcurrentOperationsPositive(
	t *testing.T,
	volumeName1 v1.UniqueVolumeName,
	podName1 volumetypes.UniquePodName,
	nodeName1 types.NodeName,
	volumeName2 v1.UniqueVolumeName,
	podName2 volumetypes.UniquePodName,
	nodeName2 types.NodeName) { … }

// testConcurrentOperationsNegative passes if the creation of the second
// operation returns an alreadyExists error, and fails otherwise.
func testConcurrentOperationsNegative(
	t *testing.T,
	volumeName1 v1.UniqueVolumeName,
	podName1 volumetypes.UniquePodName,
	nodeName1 types.NodeName,
	volumeName2 v1.UniqueVolumeName,
	podName2 volumetypes.UniquePodName,
	nodeName2 types.NodeName) { … }

func generateCallbackFunc(done chan<- interface{ … }

func generateWaitFunc(done <-chan interface{ … }

func panicFunc() volumetypes.OperationContext { … }

func errorFunc() volumetypes.OperationContext { … }

func generateWaitWithErrorFunc(done <-chan interface{ … }

func noopFunc() volumetypes.OperationContext { … }

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

func waitChannelWithTimeout(ch <-chan interface{ … }

func Test_NestedPendingOperations_OperationExists_PendingFirst(t *testing.T) { … }

func Test_NestedPendingOperations_OperationExists_ExactMatchFirstNoPending(t *testing.T) { … }