- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 873 for NodeName (0.27 sec)
-
pkg/volume/iscsi/attacher.go
return mounter.GetMountRefs(deviceMountPath) } func (attacher *iscsiAttacher) Attach(spec *volume.Spec, nodeName types.NodeName) (string, error) { return "", nil } func (attacher *iscsiAttacher) VolumesAreAttached(specs []*volume.Spec, nodeName types.NodeName) (map[*volume.Spec]bool, error) { volumesAttachedCheck := make(map[*volume.Spec]bool) for _, spec := range specs {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 04 08:51:31 UTC 2022 - 6.8K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/fakegenerator.go
return f.recordFuncCall("GenerateDetachVolumeFunc"), nil } func (f *fakeOGCounter) GenerateVolumesAreAttachedFunc(attachedVolumes []AttachedVolume, nodeName types.NodeName, actualStateOfWorld ActualStateOfWorldAttacherUpdater) (volumetypes.GeneratedOperations, error) { return f.recordFuncCall("GenerateVolumesAreAttachedFunc"), nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/metrics/metrics.go
for _, pod := range pods { if len(pod.Spec.Volumes) <= 0 { continue } if pod.Spec.NodeName == "" { continue } for _, podVolume := range pod.Spec.Volumes { volumeSpec, err := util.CreateVolumeSpec(logger, podVolume, pod, types.NodeName(pod.Spec.NodeName), collector.volumePluginMgr, collector.pvcLister, collector.pvLister, collector.csiMigratedPluginManager, collector.intreeToCSITranslator)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 10 06:30:05 UTC 2023 - 7.5K bytes - Viewed (0) -
cmd/kubemark/app/hollow_node.go
return bootstrap.LoadClientCert(context.TODO(), c.KubeconfigPath, c.BootstrapKubeconfigPath, c.CertDirectory, types.NodeName(c.NodeName)) } return nil } func (c *hollowNodeConfig) createHollowKubeletOptions() *kubemark.HollowKubeletOptions { return &kubemark.HollowKubeletOptions{ NodeName: c.NodeName, KubeletPort: c.KubeletPort, KubeletReadOnlyPort: c.KubeletReadOnlyPort,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 11K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go
ResourceVersion: 2, }, { Type: watch.Modified, PrevObject: &v1.Pod{ObjectMeta: metav1.ObjectMeta{ResourceVersion: "2"}}, PrevObjFields: fields.Set{"spec.nodeName": ""}, Object: &v1.Pod{ObjectMeta: metav1.ObjectMeta{ResourceVersion: "3"}}, ObjFields: fields.Set{"spec.nodeName": "host"}, ResourceVersion: 3, }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 22.9K bytes - Viewed (0) -
pkg/volume/fc/attacher.go
return mounter.GetMountRefs(deviceMountPath) } func (attacher *fcAttacher) Attach(spec *volume.Spec, nodeName types.NodeName) (string, error) { return "", nil } func (attacher *fcAttacher) VolumesAreAttached(specs []*volume.Spec, nodeName types.NodeName) (map[*volume.Spec]bool, error) { volumesAttachedCheck := make(map[*volume.Spec]bool) for _, spec := range specs {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 31 12:02:51 UTC 2022 - 7.5K bytes - Viewed (0) -
pkg/registry/storage/volumeattachment/strategy_test.go
ObjectMeta: metav1.ObjectMeta{ Name: name, }, Spec: storage.VolumeAttachmentSpec{ Attacher: "valid-attacher", Source: storage.VolumeAttachmentSource{ PersistentVolumeName: &name, }, NodeName: "valid-node", }, } } func getValidVolumeAttachmentWithInlineSpec(name string) *storage.VolumeAttachment { volumeAttachment := getValidVolumeAttachment(name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 8.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/statusupdater/fake_node_status_updater.go
if fnsu.returnError { return fmt.Errorf("fake error on update node status") } return nil } func (fnsu *fakeNodeStatusUpdater) UpdateNodeStatusForNode(logger klog.Logger, nodeName types.NodeName) error { if fnsu.returnError { return fmt.Errorf("fake error on update node status") } return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 1.2K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/project/harness/Xpp3DomNodeIterator.java
private boolean testNode(XmlNode node) { if (test == null) { return true; } if (test instanceof NodeNameTest) { String nodeName = node.getName(); if (nodeName == null || nodeName.isEmpty()) { return false; } NodeNameTest nodeNameTest = (NodeNameTest) test; String namespaceURI = nodeNameTest.getNamespaceURI();
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 4.5K bytes - Viewed (0) -
pkg/volume/flexvolume/attacher.go
} func (a *flexVolumeAttacher) VolumesAreAttached(specs []*volume.Spec, nodeName types.NodeName) (map[*volume.Spec]bool, error) { volumesAttachedCheck := make(map[*volume.Spec]bool) for _, spec := range specs { volumesAttachedCheck[spec] = true call := a.plugin.NewDriverCall(isAttached) call.AppendSpec(spec, a.plugin.host, nil) call.Append(string(nodeName)) status, err := call.Run() if isCmdNotSupportedErr(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 03 23:29:42 UTC 2021 - 3.6K bytes - Viewed (0)