- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 151 for volumeID (0.29 sec)
-
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) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
logger.Error(err, "Volume deletion encountered", "volumeName", volume.Name) } else { logger.V(4).Info("volume deleted", "volumeName", volume.Name) } // record deletion metric if a deletion start timestamp is in the cache // the following calls will be a no-op if there is nothing for this volume in the cache // end of timestamp cache entry lifecycle, "RecordMetric" will do the clean
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
kcache "k8s.io/client-go/tools/cache" "k8s.io/kubernetes/pkg/controller" "k8s.io/kubernetes/pkg/controller/volume/attachdetach/cache" controllervolumetesting "k8s.io/kubernetes/pkg/controller/volume/attachdetach/testing" "k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume/csi" "k8s.io/kubernetes/pkg/volume/util" "k8s.io/kubernetes/test/utils/ktesting" ) const ( intreePDUniqueNamePrefix = "kubernetes.io/gce-pd/"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/volume/local/local.go
return []volume.VolumePlugin{&localVolumePlugin{}} } type localVolumePlugin struct { host volume.VolumeHost volumeLocks keymutex.KeyMutex recorder record.EventRecorder } var _ volume.VolumePlugin = &localVolumePlugin{} var _ volume.PersistentVolumePlugin = &localVolumePlugin{} var _ volume.BlockVolumePlugin = &localVolumePlugin{} var _ volume.NodeExpandableVolumePlugin = &localVolumePlugin{} const (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/volume/downwardapi/downwardapi.go
type downwardAPIPlugin struct { host volume.VolumeHost } var _ volume.VolumePlugin = &downwardAPIPlugin{} func getPath(uid types.UID, volName string, host volume.VolumeHost) string { return host.GetPodVolumeDir(uid, utilstrings.EscapeQualifiedName(downwardAPIPluginName), volName) } func wrappedVolumeSpec() volume.Spec { return volume.Spec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/volume/emptydir/empty_dir.go
return "", fmt.Errorf("Spec does not reference an EmptyDir volume type") } // Return user defined volume name, since this is an ephemeral volume type return spec.Name(), nil } func (plugin *emptyDirPlugin) CanSupport(spec *volume.Spec) bool { return spec.Volume != nil && spec.Volume.EmptyDir != nil } func (plugin *emptyDirPlugin) RequiresRemount(spec *volume.Spec) bool { return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 19K bytes - Viewed (0) -
pkg/volume/util/util.go
func IsLocalEphemeralVolume(volume v1.Volume) bool { return volume.GitRepo != nil || (volume.EmptyDir != nil && volume.EmptyDir.Medium == v1.StorageMediumDefault) || volume.ConfigMap != nil } // GetLocalPersistentVolumeNodeNames returns the node affinity node name(s) for // local PersistentVolumes. nil is returned if the PV does not have any
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.8K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils.go
} // storageMatches returns true if pod's Volumes cover the set of PersistentVolumeClaims func storageMatches(set *apps.StatefulSet, pod *v1.Pod) bool { ordinal := getOrdinal(pod) if ordinal < 0 { return false } volumes := make(map[string]v1.Volume, len(pod.Spec.Volumes)) for _, volume := range pod.Spec.Volumes { volumes[volume.Name] = volume } for _, claim := range set.Spec.VolumeClaimTemplates {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 26.7K bytes - Viewed (0) -
cmd/storage-rest-client.go
return client.diskInfoCache.GetWithCtx(ctx) } // MakeVolBulk - create multiple volumes in a bulk operation. func (client *storageRESTClient) MakeVolBulk(ctx context.Context, volumes ...string) (err error) { return errInvalidArgument } // MakeVol - create a volume on a remote disk. func (client *storageRESTClient) MakeVol(ctx context.Context, volume string) (err error) { return errInvalidArgument }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.4K bytes - Viewed (0) -
pkg/api/pod/util.go
return true } } return false } // hasNonLocalProjectedTokenPath return true if spec.Volumes have any entry with non-local projected token path func hasNonLocalProjectedTokenPath(spec *api.PodSpec) bool { for _, volume := range spec.Volumes { if volume.Projected != nil { for _, source := range volume.Projected.Sources { if source.ServiceAccountToken == nil { continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 41.3K bytes - Viewed (0)