- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 253 for podAdd (0.14 sec)
-
pkg/kubelet/kubelet_volumes.go
volumePaths, err := kl.getMountedVolumePathListFromDisk(podUID) if err != nil { klog.ErrorS(err, "Pod found, but error occurred during checking mounted volumes from disk", "podUID", podUID) return true } if len(volumePaths) > 0 { klog.V(4).InfoS("Pod found, but volumes are still mounted on disk", "podUID", podUID, "paths", volumePaths) return true } return false }
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/kubelet_getters.go
func (kl *Kubelet) getPodVolumeSubpathsDir(podUID types.UID) string { return filepath.Join(kl.getPodDir(podUID), config.DefaultKubeletVolumeSubpathsDirName) } // getPodVolumesDir returns the full path to the per-pod data directory under // which volumes are created for the specified pod. This directory may not // exist if the pod does not exist. func (kl *Kubelet) getPodVolumesDir(podUID types.UID) string {
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/kubelet_volumes_linux_test.go
if err := tc.validateFunc(kubelet); err != nil { t.Errorf("%s failed validation: %v", name, err) } } }) } } func TestPodVolumesExistWithMount(t *testing.T) { poduid := types.UID("poduid") testCases := map[string]struct { prepareFunc func(kubelet *Kubelet) error expected bool }{ "noncsivolume-dir-not-exist": { prepareFunc: func(kubelet *Kubelet) error { return nil
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/cm/cpumanager/state/state_checkpoint.go
} for containerID, cset := range src.Entries { podUID, containerName, err := sc.initialContainers.GetContainerRef(containerID) if err != nil { return fmt.Errorf("containerID '%v' not found in initial containers list", containerID) } if dst.Entries == nil { dst.Entries = make(map[string]map[string]string) } if _, exists := dst.Entries[podUID]; !exists { dst.Entries[podUID] = make(map[string]string) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 00:59:30 UTC 2023 - 7.9K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/fake_topology_manager_test.go
name string containerName string podUID string expected TopologyHint }{ { name: "Case1", containerName: "nginx", podUID: "0aafa4c4-38e8-11e9-bcb1-a4bf01040474", expected: TopologyHint{}, }, } for _, tc := range tcases { fm := fakeManager{} actual := fm.GetAffinity(tc.podUID, tc.containerName) if !reflect.DeepEqual(actual, tc.expected) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 10 11:44:15 UTC 2021 - 2.8K bytes - Viewed (0) -
pkg/kubelet/util/pod_startup_latency_tracker.go
type PodStartupLatencyTracker interface { ObservedPodOnWatch(pod *v1.Pod, when time.Time) RecordImageStartedPulling(podUID types.UID) RecordImageFinishedPulling(podUID types.UID) RecordStatusUpdated(pod *v1.Pod) DeletePodStartupState(podUID types.UID) } type basicPodStartupLatencyTracker struct { // protect against concurrent read and write on pods map lock sync.Mutex
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 15 06:09:49 UTC 2023 - 5.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
pod := buildConvincingPod(false) var podUID string = string(pod.ObjectMeta.UID) fakeIPSetDeps := ipset.FakeNLDeps() set := ipset.IPSet{V4Name: "foo-v4", Prefix: "foo", Deps: fakeIPSetDeps} ipProto := uint8(unix.IPPROTO_TCP) fakeIPSetDeps.On("addIP", "foo-v4", netip.MustParseAddr("99.9.9.9"), ipProto, podUID, false, ).Return(nil) fakeIPSetDeps.On("addIP",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 17.8K bytes - Viewed (0) -
pkg/kubelet/cm/helpers.go
continue } podUID := podSandboxMap[c.PodSandboxId] containerMap.Add(podUID, c.Metadata.Name, c.Id) if c.State == runtimeapi.ContainerState_CONTAINER_RUNNING { klog.V(4).InfoS("Container reported running", "podSandboxId", c.PodSandboxId, "podUID", podUID, "containerName", c.Metadata.Name, "containerId", c.Id) runningSet.Insert(c.Id) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 2.8K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/testing/provider_mock.go
// GetDevices mocks base method. func (m *MockDevicesProvider) GetDevices(podUID, containerName string) []*v10.ContainerDevices { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "GetDevices", podUID, containerName) ret0, _ := ret[0].([]*v10.ContainerDevices) return ret0 } // GetDevices indicates an expected call of GetDevices. func (mr *MockDevicesProviderMockRecorder) GetDevices(podUID, containerName any) *gomock.Call { mr.mock.ctrl.T.Helper()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 10.1K bytes - Viewed (0) -
pkg/kubelet/cm/pod_container_manager_linux_test.go
expectedUID: types.UID(""), }, { input: NewCgroupName(qosContainersInfo.Guaranteed, GetPodCgroupNameSuffix(podUID)), expectedResult: true, expectedUID: podUID, }, { input: NewCgroupName(qosContainersInfo.Guaranteed, GetPodCgroupNameSuffix(podUID), "container.scope"), expectedResult: false, expectedUID: types.UID(""), }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 08 13:06:38 UTC 2022 - 8.9K bytes - Viewed (0)