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) { … }
func testConcurrentOperationsPositive(
t *testing.T,
volumeName1 v1.UniqueVolumeName,
podName1 volumetypes.UniquePodName,
nodeName1 types.NodeName,
volumeName2 v1.UniqueVolumeName,
podName2 volumetypes.UniquePodName,
nodeName2 types.NodeName) { … }
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) { … }