- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 50 for csiNode (0.3 sec)
-
pkg/scheduler/framework/plugins/nodevolumelimits/csi_test.go
t.Run(test.test, func(t *testing.T) { node, csiNode := getNodeWithPodAndVolumeLimits(test.limitSource, test.existingPods, test.maxVols, test.driverNames...) if csiNode != nil { enableMigrationOnNode(csiNode, csilibplugins.AWSEBSInTreePluginName) } csiTranslator := csitrans.New() p := &CSILimits{ csiNodeLister: getFakeCSINodeLister(csiNode),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 18:07:11 UTC 2024 - 28.6K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager_test.go
migratedPlugins map[string](func() bool) existingNode *storage.CSINode expectedNode *storage.CSINode expectModified bool }{ { name: "nil migrated plugins", existingNode: &storage.CSINode{ ObjectMeta: metav1.ObjectMeta{ Name: "node1", }, }, expectedNode: &storage.CSINode{ ObjectMeta: metav1.ObjectMeta{ Name: "node1", }, }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 17 02:02:59 UTC 2022 - 34.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/csi.go
translator: csiTranslator, }, nil } func getVolumeLimits(nodeInfo *framework.NodeInfo, csiNode *storagev1.CSINode) map[v1.ResourceName]int64 { // TODO: stop getting values from Node object in v1.18 nodeVolumeLimits := volumeLimits(nodeInfo) if csiNode != nil { for i := range csiNode.Spec.Drivers { d := csiNode.Spec.Drivers[i] if d.Allocatable != nil && d.Allocatable.Count != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 18:07:11 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager.go
} } // InstallCSIDriver updates the node ID annotation in the Node object and CSIDrivers field in the // CSINode object. If the CSINode object doesn't yet exist, it will be created. // If multiple calls to InstallCSIDriver() are made in parallel, some calls might receive Node or // CSINode update conflicts, which causes the function to retry the corresponding update.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/non_csi.go
return nil } node := nodeInfo.Node() var csiNode *storage.CSINode var err error if pl.csiNodeLister != nil { csiNode, err = pl.csiNodeLister.Get(node.Name) if err != nil { // we don't fail here because the CSINode object is only necessary // for determining whether the migration is enabled or not logger.V(5).Info("Could not get a CSINode object for the node", "node", klog.KObj(node), "err", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 30 23:00:56 UTC 2023 - 19.6K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
csiNode := &storagev1.CSINode{ ObjectMeta: metav1.ObjectMeta{Name: f.nodeName}, Spec: storagev1.CSINodeSpec{ Drivers: []storagev1.CSINodeDriver{}, }, } enableMigrationOnNode(csiNode, csilibplugins.GCEPDInTreePluginName) return getFakeCSINodeLister(csiNode) } func enableMigrationOnNode(csiNode *storagev1.CSINode, pluginName string) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_listers.go
// CSINodeLister declares a storagev1.CSINode type for testing. type CSINodeLister []storagev1.CSINode // Get returns a fake CSINode object. func (n CSINodeLister) Get(name string) (*storagev1.CSINode, error) { for _, cn := range n { if cn.Name == name { return &cn, nil } } return nil, errors.NewNotFound(storagev1.Resource("csinodes"), name) } // List lists all CSINodes in the indexer.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 20 10:14:08 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/apis/storage/v1/zz_generated.conversion.go
return err } if err := s.AddGeneratedConversionFunc((*v1.CSINode)(nil), (*storage.CSINode)(nil), func(a, b interface{}, scope conversion.Scope) error { return Convert_v1_CSINode_To_storage_CSINode(a.(*v1.CSINode), b.(*storage.CSINode), scope) }); err != nil { return err } if err := s.AddGeneratedConversionFunc((*storage.CSINode)(nil), (*v1.CSINode)(nil), func(a, b interface{}, scope conversion.Scope) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 04 08:51:01 UTC 2022 - 39.2K bytes - Viewed (0) -
pkg/apis/storage/v1beta1/zz_generated.conversion.go
return err } if err := s.AddGeneratedConversionFunc((*v1beta1.CSINode)(nil), (*storage.CSINode)(nil), func(a, b interface{}, scope conversion.Scope) error { return Convert_v1beta1_CSINode_To_storage_CSINode(a.(*v1beta1.CSINode), b.(*storage.CSINode), scope) }); err != nil { return err } if err := s.AddGeneratedConversionFunc((*storage.CSINode)(nil), (*v1beta1.CSINode)(nil), func(a, b interface{}, scope conversion.Scope) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 04 08:51:01 UTC 2022 - 41K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
return nil } kubeClient := host.GetKubeClient() if kubeClient == nil { // Kubelet running in standalone mode. Skip CSINode initialization klog.Warning("Skipping CSINode initialization, kubelet running in standalone mode") return nil } kvh.SetKubeletError(errors.New("CSINode is not yet initialized")) go func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0)