- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for VerifyVolumesAreAttachedPerNode (0.36 sec)
-
pkg/volume/util/operationexecutor/operation_executor.go
for node, nodeAttachedVolumes := range attachedVolumes { nodeError := oe.VerifyVolumesAreAttachedPerNode(nodeAttachedVolumes, node, actualStateOfWorld) if nodeError != nil { klog.Errorf("VerifyVolumesAreAttached failed for volumes %v, node %q with error %v", nodeAttachedVolumes, node, nodeError) } } } func (oe *operationExecutor) VerifyVolumesAreAttachedPerNode( attachedVolumes []AttachedVolume, nodeName types.NodeName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_executor_test.go
} func TestOperationExecutor_VerifyVolumesAreAttachedConcurrentlyOnSameNode(t *testing.T) { // Arrange ch, quit, oe := setup() // Act for i := 0; i < numVolumesToVerifyAttached; i++ { oe.VerifyVolumesAreAttachedPerNode(nil /* attachedVolumes */, "node-name", nil /* actualStateOfWorldAttacherUpdater */) } // Assert if !isOperationRunConcurrently(ch, quit, numVolumesToVerifyAttached) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 26.9K bytes - Viewed (0)