- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 36 for volumeattachment (0.18 sec)
-
pkg/controller/volume/attachdetach/attach_detach_controller.go
csiDriverLister storagelistersv1.CSIDriverLister csiDriversSynced kcache.InformerSynced // volumeAttachmentLister is the shared volumeAttachment lister used to fetch and store // VolumeAttachment objects from the API server. It is shared with other controllers // and therefore the VolumeAttachment objects in its store should be treated as immutable. volumeAttachmentLister storagelistersv1.VolumeAttachmentLister
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/node_authorizer_test.go
nodes := make([]*corev1.Node, 0, opts.nodes) pods := make([]*corev1.Pod, 0, opts.nodes*opts.podsPerNode) pvs := make([]*corev1.PersistentVolume, 0, (opts.nodes*opts.podsPerNode*opts.uniquePVCsPerPod)+(opts.sharedPVCsPerPod*opts.namespaces)) attachments := make([]*storagev1.VolumeAttachment, 0, opts.nodes*opts.attachmentsPerNode)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 40.5K bytes - Viewed (0) -
pkg/volume/csi/csi_test.go
var volAttacher volume.Attacher volAttacher, err := attachPlug.NewAttacher() if err != nil { t.Fatal("csiTest.VolumeAll failed to create new attacher: ", err) } // creates VolumeAttachment and blocks until it is marked attached (done by external attacher) go func() { attachID, err := volAttacher.Attach(volSpec, attachDetachVolumeHost.GetNodeName()) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 15:55:13 UTC 2022 - 21.1K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
// search for attachment by VolumeAttachment.Spec.Source.PersistentVolumeName attachment, err := client.StorageV1().VolumeAttachments().Get(context.TODO(), attachID, meta.GetOptions{}) if err != nil { return nil, err // This err already has enough context ("VolumeAttachment xyz not found") } if attachment == nil { err = errors.New("no existing VolumeAttachment found") return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
newVa := controllervolumetesting.NewVolumeAttachment(tc.vaName, tc.pvName, tc.vaNodeName, tc.vaAttachStatus) _, err = adc.kubeClient.StorageV1().VolumeAttachments().Create(tCtx, newVa, metav1.CreateOptions{}) if err != nil { t.Fatalf("Run failed with error. Failed to create a new volumeAttachment: <%v>", err) } vaInformer.GetIndexer().Add(newVa) } // Makesure the informer cache is synced informerFactory.Start(tCtx.Done())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph.go
podVertexType: "pod", pvcVertexType: "pvc", pvVertexType: "pv", resourceClaimVertexType: "resourceclaim", secretVertexType: "secret", vaVertexType: "volumeattachment", serviceAccountVertexType: "serviceAccount", } // must be called under a write lock func (g *Graph) getOrCreateVertex_locked(vertexType vertexType, namespace, name string) *namedVertex {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 17.5K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter.go
deviceMountPath, err = makeDeviceMountPath(c.plugin, c.spec) if err != nil { return errors.New(log("mounter.SetUpAt failed to make device mount path: %v", err)) } } // search for attachment by VolumeAttachment.Spec.Source.PersistentVolumeName if c.publishContext == nil { nodeName := string(c.plugin.host.GetNodeName()) c.publishContext, err = c.plugin.getPublishContext(c.k8s, volumeHandle, string(driverName), nodeName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 30 10:47:59 UTC 2024 - 21K bytes - Viewed (1) -
pkg/volume/plugins.go
// CSIDriverLister returns the informer lister for the CSIDriver API Object CSIDriverLister() storagelistersv1.CSIDriverLister // VolumeAttachmentLister returns the informer lister for the VolumeAttachment API Object VolumeAttachmentLister() storagelistersv1.VolumeAttachmentLister // IsAttachDetachController is an interface marker to strictly tie AttachDetachVolumeHost // to the attachDetachController
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/util/util_test.go
csiDriverInformer := factory.Storage().V1().CSIDrivers() csiDriverLister := csiDriverInformer.Lister() volumeAttachmentInformer := factory.Storage().V1().VolumeAttachments() volumeAttachmentLister := volumeAttachmentInformer.Lister() plugMgr := &volume.VolumePluginMgr{} fakeAttachDetachVolumeHost := volumetest.NewFakeAttachDetachVolumeHostWithCSINodeName(t, tmpDir,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 12 05:42:38 UTC 2023 - 10.4K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/node_authorizer.go
pvResource = api.Resource("persistentvolumes") resourceClaimResource = resourceapi.Resource("resourceclaims") vaResource = storageapi.Resource("volumeattachments") svcAcctResource = api.Resource("serviceaccounts") leaseResource = coordapi.Resource("leases") csiNodeResource = storageapi.Resource("csinodes") )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 16K bytes - Viewed (0)