- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 115 for csiNode (0.25 sec)
-
pkg/registry/storage/csinode/storage/storage.go
NewListFunc: func() runtime.Object { return &storageapi.CSINodeList{} }, DefaultQualifiedResource: storageapi.Resource("csinodes"), SingularQualifiedResource: storageapi.Resource("csinode"), CreateStrategy: csinode.Strategy, UpdateStrategy: csinode.Strategy, DeleteStrategy: csinode.Strategy, ReturnDeletedObject: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:13 UTC 2022 - 2.1K bytes - Viewed (0) -
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/registry/storage/csinode/strategy.go
} func (csiNodeStrategy) Validate(ctx context.Context, obj runtime.Object) field.ErrorList { csiNode := obj.(*storage.CSINode) validateOptions := validation.CSINodeValidationOptions{ AllowLongNodeID: true, } errs := validation.ValidateCSINode(csiNode, validateOptions) return errs } // WarningsOnCreate returns warnings for the creation of the given object.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 26 00:30:42 UTC 2021 - 2.9K 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) -
api/discovery/apis__storage.k8s.io__v1.json
"deletecollection", "get", "list", "patch", "update", "watch" ] }, { "kind": "CSINode", "name": "csinodes", "namespaced": false, "singularName": "csinode", "storageVersionHash": "Pe62DkZtjuo=", "verbs": [ "create", "delete", "deletecollection", "get", "list",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 15 18:18:19 UTC 2023 - 2.1K bytes - Viewed (0) -
pkg/registry/storage/csinode/doc.go
See the License for the specific language governing permissions and limitations under the License. */ // Package csinode provides Registry interface and its REST // implementation for storing csinode api objects.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 20:31:05 UTC 2019 - 698 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)