- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 386 for Mounts (0.1 sec)
-
cmd/kubeadm/app/phases/controlplane/volumes.go
mounts.AddExtraHostPathMounts(kubeadmconstants.KubeAPIServer, cfg.APIServer.ExtraVolumes) mounts.AddExtraHostPathMounts(kubeadmconstants.KubeControllerManager, cfg.ControllerManager.ExtraVolumes) mounts.AddExtraHostPathMounts(kubeadmconstants.KubeScheduler, cfg.Scheduler.ExtraVolumes) return mounts } // controlPlaneHostPathMounts is a helper struct for handling all the control plane's hostPath mounts in an easy way
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 09:33:18 UTC 2024 - 11.3K bytes - Viewed (0) -
cmd/kubeadm/app/phases/controlplane/volumes_test.go
t.Run(rt.name, func(t *testing.T) { mounts := getHostPathVolumesForTheControlPlane(rt.cfg) // Avoid unit test errors when the flexvolume is mounted delete(mounts.volumes[kubeadmconstants.KubeControllerManager], flexvolumeDirVolumeName) delete(mounts.volumeMounts[kubeadmconstants.KubeControllerManager], flexvolumeDirVolumeName) if !reflect.DeepEqual(mounts.volumes, rt.vol) { t.Errorf(
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/kubelet/cm/helpers_linux.go
mountPoints[controller] = util.CgroupRoot m := libcontainercgroups.Mount{ Mountpoint: util.CgroupRoot, Root: util.CgroupRoot, Subsystems: []string{controller}, } mounts = append(mounts, m) } return &CgroupSubsystems{ Mounts: mounts, MountPoints: mountPoints, }, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 11:52:28 UTC 2023 - 9.8K bytes - Viewed (0) -
pkg/volume/util/util_test.go
}, expected: false, }, "extra local mount": { mountPath: "/var/lib/kubelet/plugins/kubernetes.io/some-plugin/mounts/volume-XXXX", mountRefs: []string{ "/home/somewhere/var/lib/kubelet/plugins/kubernetes.io/some-plugin/mounts/volume-XXXX", "/local/data/kubernetes.io/some-plugin/mounts/volume-XXXX", "/mnt/kubelet/plugins/kubernetes.io/some-plugin/mounts/volume-XXXX",
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/kubelet/kubelet_pods_linux_test.go
t.Fatalf("expected error message `%s` but got `%v`", tc.expectedErrMsg, err) } return } // otherwise validate the mounts if err != nil { t.Fatal(err) } assert.Equal(t, tc.expectedMounts, mounts, "mounts of container %+v", tc.container) }) } } func TestMakeBlockVolumes(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 18:00:59 UTC 2024 - 11.3K bytes - Viewed (0) -
cmd/kubeadm/app/phases/controlplane/manifests.go
func GetStaticPodSpecs(cfg *kubeadmapi.ClusterConfiguration, endpoint *kubeadmapi.APIEndpoint, proxyEnvs []kubeadmapi.EnvVar) map[string]v1.Pod { // Get the required hostpath mounts mounts := getHostPathVolumesForTheControlPlane(cfg) if proxyEnvs == nil { proxyEnvs = kubeadmutil.GetProxyEnvVars() } componentHealthCheckTimeout := kubeadmapi.GetActiveTimeouts().ControlPlaneComponentHealthCheck
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Mar 03 14:43:47 UTC 2024 - 17.8K bytes - Viewed (0) -
plugin/pkg/admission/serviceaccount/admission_test.go
ObjectMeta: metav1.ObjectMeta{ Name: serviceAccountName, Namespace: ns, UID: types.UID(serviceAccountUID), }, }) // Define a pod with a container that already mounts a volume at the API token path // Admission should respect that // Additionally, no volume should be created if no container is going to use it pod := &api.Pod{ Spec: api.PodSpec{ Containers: []api.Container{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 17:49:30 UTC 2024 - 36.9K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/pod_devices.go
} continue } klog.V(4).InfoS("Add mount", "containerPath", mount.ContainerPath, "hostPath", mount.HostPath) mountsMap[mount.ContainerPath] = mount.HostPath opts.Mounts = append(opts.Mounts, kubecontainer.Mount{ Name: mount.ContainerPath, ContainerPath: mount.ContainerPath, HostPath: mount.HostPath, ReadOnly: mount.ReadOnly, // TODO: This may need to be part of Device plugin API.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/volume/util/util.go
// script will cause additional mounts created in the container. Since these mounts are // irrelevant to the original mounts, they should be not considered when checking the // mount references. The current solution is to filter out those mount paths that contain // the k8s plugin suffix of original mount path. func HasMountRefs(mountPath string, mountRefs []string) bool {
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/volume/util/hostutil/hostutil_linux.go
} // FindMountInfo returns the mount info on the given path. func (hu *HostUtil) FindMountInfo(path string) (mount.MountInfo, error) { return findMountInfo(path, procMountInfoPath) } // isShared returns true, if given path is on a mount point that has shared // mount propagation. func isShared(mount string, mountInfoPath string) (bool, error) { info, err := findMountInfo(mount, mountInfoPath) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 23 08:36:44 UTC 2023 - 10K bytes - Viewed (0)