- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 394 for volumeID (0.12 sec)
-
pkg/volume/fc/fc_test.go
} if plug.CanSupport(&volume.Spec{}) { t.Errorf("Expected false") } if plug.CanSupport(&volume.Spec{Volume: &v1.Volume{VolumeSource: v1.VolumeSource{}}}) { t.Errorf("Expected false") } if !plug.CanSupport(&volume.Spec{Volume: &v1.Volume{VolumeSource: v1.VolumeSource{FC: &v1.FCVolumeSource{}}}}) { t.Errorf("Expected true") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 01 15:56:32 UTC 2022 - 14.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler.go
continue } // Before triggering volume detach, mark volume as detached and update the node status // If it fails to update node status, skip detach volume // If volume detach operation fails, the volume needs to be added back to report as attached so that node status // has the correct volume attachment information.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 21:02:38 UTC 2024 - 21.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumezone/volume_zone.go
logger := klog.FromContext(ctx) podPVTopologies := make([]pvTopology, 0) for i := range pod.Spec.Volumes { volume := pod.Spec.Volumes[i] if volume.PersistentVolumeClaim == nil { continue } pvcName := volume.PersistentVolumeClaim.ClaimName if pvcName == "" { return nil, framework.NewStatus(framework.UnschedulableAndUnresolvable, "PersistentVolumeClaim had no name")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
"k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume/csimigration" "k8s.io/kubernetes/pkg/volume/util" volumetypes "k8s.io/kubernetes/pkg/volume/util/types" ) // DesiredStateOfWorldPopulator periodically loops through the list of active // pods and ensures that each one exists in the desired state of the world cache // if it has volumes. It also verifies that the pods in the desired state of the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
pkg/volume/util/util_test.go
mountRefs: []string{ "/home/somewhere/var/lib/kubelet/plugins/kubernetes.io/some-plugin/mounts/volume-XXXX", "/var/lib/kubelet/plugins/kubernetes.io/some-plugin/mounts/volume-XXXX", "/mnt/kubelet/plugins/kubernetes.io/some-plugin/mounts/volume-XXXX", "/mnt/plugins/kubernetes.io/some-plugin/mounts/volume-XXXX", }, expected: false, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder.go
return pvc.Spec.VolumeName != "" && metav1.HasAnnotation(pvc.ObjectMeta, volume.AnnBindCompleted) } // arePodVolumesBound returns true if all volumes are fully bound func (b *volumeBinder) arePodVolumesBound(logger klog.Logger, pod *v1.Pod) bool { for _, vol := range pod.Spec.Volumes { if isBound, _, _ := b.isVolumeBound(logger, pod, &vol); !isBound {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/volume/fc/fc.go
"k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume/util" "k8s.io/kubernetes/pkg/volume/util/volumepathhandler" ) // ProbeVolumePlugins is the primary entrypoint for volume plugins. func ProbeVolumePlugins() []volume.VolumePlugin { return []volume.VolumePlugin{&fcPlugin{nil}} } type fcPlugin struct { host volume.VolumeHost } var _ volume.VolumePlugin = &fcPlugin{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 17.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager_test.go
containertest "k8s.io/kubernetes/pkg/kubelet/container/testing" kubepod "k8s.io/kubernetes/pkg/kubelet/pod" "k8s.io/kubernetes/pkg/volume" volumetest "k8s.io/kubernetes/pkg/volume/testing" "k8s.io/kubernetes/pkg/volume/util" "k8s.io/kubernetes/pkg/volume/util/hostutil" "k8s.io/kubernetes/pkg/volume/util/types" ) const ( testHostname = "test-hostname" ) func TestGetMountedVolumesForPodAndGetVolumesInUse(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.1K bytes - Viewed (0) -
plugin/pkg/admission/serviceaccount/admission_test.go
} if len(pod.Spec.Volumes) != 1 { t.Fatalf("Expected 1 volume, got %d", len(pod.Spec.Volumes)) } if !reflect.DeepEqual(expectedVolume, pod.Spec.Volumes[0]) { t.Fatalf("Expected\n\t%#v\ngot\n\t%#v", expectedVolume, pod.Spec.Volumes[0]) } if len(pod.Spec.Containers[0].VolumeMounts) != 1 { t.Fatalf("Expected 1 volume mount, got %d", len(pod.Spec.Containers[0].VolumeMounts)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 17:49:30 UTC 2024 - 36.9K bytes - Viewed (0) -
cmd/kubeadm/app/phases/controlplane/volumes_test.go
t.Run(hostMount.Name, func(t *testing.T) { volumeName := hostMount.Name if _, ok := mounts.volumes["component"][volumeName]; !ok { t.Errorf("Expected to find volume %q", volumeName) } vol := mounts.volumes["component"][volumeName] if vol.Name != volumeName { t.Errorf("Expected volume name %q", volumeName) } if vol.HostPath.Path != hostMount.HostPath {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 09:33:18 UTC 2024 - 18.1K bytes - Viewed (0)