- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for GetPodDir (3.71 sec)
-
pkg/kubelet/kubelet_volumes_linux_test.go
podDir := kubelet.getPodDir("pod1uid") return os.MkdirAll(filepath.Join(podDir, "volumes/plugin/name"), 0750) }, validateFunc: func(kubelet *Kubelet) error { podDir := kubelet.getPodDir("pod1uid") return validateDirNotExists(podDir) }, }, "pod-doesnot-exist-with-volume-subdir": { prepareFunc: func(kubelet *Kubelet) error { podDir := kubelet.getPodDir("pod1uid")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 30 03:35:26 UTC 2022 - 8.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_getters.go
return filepath.Join(kl.getVolumeDevicePluginsDir(), pluginName, config.DefaultKubeletVolumeDevicesDirName) } // GetPodDir returns the full path to the per-pod data directory for the // specified pod. This directory may not exist if the pod does not exist. func (kl *Kubelet) GetPodDir(podUID types.UID) string { return kl.getPodDir(podUID) } // ListPodsFromDisk gets a list of pods that have data directories.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/kubelet/userns/userns_manager.go
// since Go maps never free memory. const mapReInitializeThreshold = 1000 type userNsPodsManager interface { HandlerSupportsUserNamespaces(runtimeHandler string) (bool, error) GetPodDir(podUID types.UID) string ListPodsFromDisk() ([]types.UID, error) GetKubeletMappings() (uint32, uint32, error) GetMaxPods() int } type UsernsManager struct { used *allocator.AllocationBitmap
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/kubelet/container/testing/fake_runtime_helper.go
} // This is not used by docker runtime. func (f *FakeRuntimeHelper) GeneratePodHostNameAndDomain(pod *v1.Pod) (string, string, error) { return f.HostName, f.HostDomain, f.Err } func (f *FakeRuntimeHelper) GetPodDir(podUID kubetypes.UID) string { return "/poddir/" + string(podUID) } func (f *FakeRuntimeHelper) GetExtraSupplementalGroupsForPod(pod *v1.Pod) []int64 { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 11:01:00 UTC 2024 - 2.4K bytes - Viewed (0) -
pkg/kubelet/kubelet_getters_test.go
exp = filepath.Join(root, "plugins_registry") assert.Equal(t, exp, got) got = kubelet.getPluginDir("foobar") exp = filepath.Join(root, "plugins/foobar") assert.Equal(t, exp, got) got = kubelet.getPodDir("abc123") exp = filepath.Join(root, "pods/abc123") assert.Equal(t, exp, got) got = kubelet.getPodVolumesDir("abc123") exp = filepath.Join(root, "pods/abc123/volumes") assert.Equal(t, exp, got)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/kubelet/userns/userns_manager_test.go
type testUserNsPodsManager struct { podDir string podList []types.UID userns bool maxPods int mappingFirstID uint32 mappingLen uint32 } func (m *testUserNsPodsManager) GetPodDir(podUID types.UID) string { if m.podDir == "" { return "/tmp/non-existant-dir.This-is-not-used-in-tests" } return m.podDir } func (m *testUserNsPodsManager) ListPodsFromDisk() ([]types.UID, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 14.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/kubelet/container/helpers.go
GetPodDNS(pod *v1.Pod) (dnsConfig *runtimeapi.DNSConfig, err error) // GetPodCgroupParent returns the CgroupName identifier, and its literal cgroupfs form on the host // of a pod. GetPodCgroupParent(pod *v1.Pod) string GetPodDir(podUID types.UID) string GeneratePodHostNameAndDomain(pod *v1.Pod) (hostname string, hostDomain string, err error) // GetExtraSupplementalGroupsForPod returns a list of the extra
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
for i := range pods { assert.True(t, dirExists(kl.getPodDir(pods[i].UID)), "Expected directory to exist for pod %d", i) } // Pod 1 has been deleted and no longer exists. kl.podManager.SetPods([]*v1.Pod{pods[0]}) kl.HandlePodCleanups(ctx) assert.True(t, dirExists(kl.getPodDir(pods[0].UID)), "Expected directory to exist for pod 0") assert.False(t, dirExists(kl.getPodDir(pods[1].UID)), "Expected directory to be deleted for pod 1")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
} opts.Envs = append(opts.Envs, envs...) // only podIPs is sent to makeMounts, as podIPs is populated even if dual-stack feature flag is not enabled. mounts, cleanupAction, err := makeMounts(pod, kl.getPodDir(pod.UID), container, hostname, hostDomainName, podIPs, volumes, kl.hostutil, kl.subpather, opts.Envs, supportsRRO) if err != nil { return nil, cleanupAction, err } opts.Mounts = append(opts.Mounts, mounts...)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0)