- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 988 for volName (0.21 sec)
-
pkg/kubelet/volumemanager/reconciler/reconstruct_common.go
return nil, fmt.Errorf("could not find block volume plugin %q (spec.Name: %q) pod %q (UID: %q)", volume.pluginName, volume.volumeSpecName, volume.podName, pod.UID) } reconstructed, err := rc.operationExecutor.ReconstructVolumeOperation( volume.volumeMode, plugin, mapperPlugin, pod.UID, volume.podName, volume.volumeSpecName, volume.volumePath, volume.pluginName) if err != nil { return nil, err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
// volume. if volume.Status.Phase != v1.VolumeReleased && volume.Status.Phase != v1.VolumeFailed { // Also, log this only once: logger.V(2).Info("Volume is released and reclaim policy will be executed", "volumeName", volume.Name, "reclaimPolicy", volume.Spec.PersistentVolumeReclaimPolicy) if volume, err = ctrl.updateVolumePhase(ctx, volume, v1.VolumeReleased, ""); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/desired_state_of_world_test.go
"k8s.io/kubernetes/pkg/features" "k8s.io/kubernetes/pkg/volume" volumetesting "k8s.io/kubernetes/pkg/volume/testing" "k8s.io/kubernetes/pkg/volume/util" volumetypes "k8s.io/kubernetes/pkg/volume/util/types" ) // Calls AddPodToVolume() to add new pod to new volume // Verifies newly added pod/volume exists via // PodExistsInVolume() VolumeExists() and GetVolumesToMount()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 34K bytes - Viewed (0) -
cmd/kubelet/app/plugins.go
"k8s.io/utils/exec" // Volume plugins "k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume/configmap" "k8s.io/kubernetes/pkg/volume/csi" "k8s.io/kubernetes/pkg/volume/downwardapi" "k8s.io/kubernetes/pkg/volume/emptydir" "k8s.io/kubernetes/pkg/volume/fc" "k8s.io/kubernetes/pkg/volume/flexvolume" "k8s.io/kubernetes/pkg/volume/git_repo" "k8s.io/kubernetes/pkg/volume/hostpath" "k8s.io/kubernetes/pkg/volume/iscsi"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 21:09:52 UTC 2024 - 3.1K bytes - Viewed (0) -
cmd/naughty-disk_test.go
func (d *naughtyDisk) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) { if err := d.calcError(); err != nil { return VolInfo{}, err } return d.disk.StatVol(ctx, volume) } func (d *naughtyDisk) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) { if err := d.calcError(); err != nil { return err } return d.disk.DeleteVol(ctx, volume, forceDelete) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 9.4K bytes - Viewed (0) -
pkg/volume/flexvolume/util.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 14 13:58:56 UTC 2021 - 4.8K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/testing/testing.go
if reflect.DeepEqual(storedVolume, volume) { logger.V(4).Info("Nothing updated volume", "volumeName", volume.Name) return true, volume, nil } // Don't modify the existing object volume = volume.DeepCopy() volume.ResourceVersion = strconv.Itoa(storedVer + 1) } else { return true, nil, fmt.Errorf("cannot update volume %s: volume not found", volume.Name) } // Store the updated object to appropriate places.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 20.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go
} // Populates data struct with a single node no volume. // Calls AddPod() with the same node and new pod/volume. // Verifies node/volume exists. // Calls AddPod() with the same node and volume different pod. // Verifies the same node/volume exists, and 1 volumes to attach. func Test_AddPod_Positive_NewPodNodeExistsVolumeExists(t *testing.T) { // Arrange
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 35.9K bytes - Viewed (0) -
pkg/volume/flexvolume/attacher.go
"k8s.io/apimachinery/pkg/types" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/volume" ) type flexVolumeAttacher struct { plugin *flexVolumeAttachablePlugin } var _ volume.Attacher = &flexVolumeAttacher{} var _ volume.DeviceMounter = &flexVolumeAttacher{} // Attach is part of the volume.Attacher interface func (a *flexVolumeAttacher) Attach(spec *volume.Spec, hostName types.NodeName) (string, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 03 23:29:42 UTC 2021 - 3.6K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world.go
// It is used to prevent reporting the error from being reported more than once for a given volume. multiAttachErrorReported bool // volumeName contains the unique identifier for this volume. volumeName v1.UniqueVolumeName // spec is the volume spec containing the specification for this volume. // Used to generate the volume plugin object, and passed to attach/detach // methods.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 13.5K bytes - Viewed (0)