Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for GetVolumesToReportAttached (0.49 sec)

  1. pkg/controller/volume/attachdetach/statusupdater/node_status_updater_test.go

    	}
    
    	needToReport := asw.GetVolumesToReportAttached(logger)
    	if len(needToReport) != 1 {
    		t.Fatalf("len(asw.GetVolumesToReportAttached()) Expected: <1> Actual: <%v>", len(needToReport))
    	}
    	if _, ok := needToReport[types.NodeName(failedNode)]; !ok {
    		t.Fatalf("GetVolumesToReportAttached() did not report correct node Expected: <%s> Actual: <%v>", failedNode, needToReport)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 8.4K bytes
    - Viewed (0)
  2. pkg/controller/volume/attachdetach/cache/actual_state_of_world.go

    	// This function is used by reconciler for multi-attach check.
    	GetNodesForAttachedVolume(volumeName v1.UniqueVolumeName) []types.NodeName
    
    	// GetVolumesToReportAttached returns a map containing the set of nodes for
    	// which the VolumesAttached Status field in the Node API object should be
    	// updated. The key in this map is the name of the node to update and the
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 07:35:17 UTC 2024
    - 28.7K bytes
    - Viewed (0)
  3. pkg/controller/volume/attachdetach/statusupdater/node_status_updater.go

    	var nodeIssues int
    	// TODO: investigate right behavior if nodeName is empty
    	// kubernetes/kubernetes/issues/37777
    	nodesToUpdate := nsu.actualStateOfWorld.GetVolumesToReportAttached(logger)
    	for nodeName, attachedVolumes := range nodesToUpdate {
    		err := nsu.processNodeVolumes(logger, nodeName, attachedVolumes)
    		if err != nil {
    			nodeIssues += 1
    		}
    	}
    	if nodeIssues > 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  4. pkg/controller/volume/attachdetach/cache/actual_state_of_world_test.go

    	}
    	verifyAttachedVolume(t, allVolumes, generatedVolumeName, string(volumeName), nodeName, devicePath, true /* expectedMountedByNode */, false /* expectNonZeroDetachRequestedTime */)
    
    	reportAsAttachedVolumesMap := asw.GetVolumesToReportAttached(logger)
    	_, exists := reportAsAttachedVolumesMap[nodeName]
    	if exists {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 07:35:17 UTC 2024
    - 66.1K bytes
    - Viewed (0)
  5. pkg/controller/volume/attachdetach/reconciler/reconciler_test.go

    	// controller then added the volume back as attached.
    	// verifyVolumeReportedAsAttachedToNode will check volume is in the list of volume attached that needs to be updated
    	// in node status. By calling this function (GetVolumesToReportAttached), node status should be updated, and the volume
    	// will not need to be updated until new changes are applied (detach is triggered again)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 07:00:14 UTC 2024
    - 72.8K bytes
    - Viewed (0)
Back to top