- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 122 for podAdd (0.31 sec)
-
pkg/kubelet/apis/podresources/server_v1_test.go
mockPodsProvider.EXPECT().GetPods().Return(tc.pods).AnyTimes() mockDevicesProvider.EXPECT().GetDevices(string(podUID), containerName).Return(tc.devices).AnyTimes() mockCPUsProvider.EXPECT().GetCPUs(string(podUID), containerName).Return(tc.cpus).AnyTimes() mockMemoryProvider.EXPECT().GetMemory(string(podUID), containerName).Return(tc.memory).AnyTimes()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 45.9K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi.go
return &iscsiDiskUnmounter{ iscsiDisk: &iscsiDisk{ podUID: podUID, VolName: volName, manager: manager, plugin: plugin,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 23.4K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager.go
} } } } m.containerMap.Visit(func(podUID, containerName, containerID string) { if _, ok := activeContainers[podUID][containerName]; !ok { klog.ErrorS(nil, "RemoveStaleState: removing container", "podUID", podUID, "containerName", containerName) err := m.policyRemoveContainerByRef(podUID, containerName) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 19.9K bytes - Viewed (2) -
pkg/volume/csi/csi_test.go
return volume.NewSpecFromPersistentVolume(makeTestPV(specName, 20, driver, volName), false) }, podFunc: func() *api.Pod { podUID := types.UID(fmt.Sprintf("%08X", rand.Uint64())) return &api.Pod{ObjectMeta: meta.ObjectMeta{UID: podUID, Namespace: testns}} }, }, { name: "PersistentVolume with driver info", specName: "pv2", driver: "simple-driver", volName: "vol2",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 15:55:13 UTC 2022 - 21.1K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
if matchResults != nil { return "", "", false } matchResults = matches } } if matchResults != nil { var podUID types.UID if matchResults["poduid"] != "" { podUID = canonicalizePodUID(matchResults["poduid"]) } return podUID, matchResults["containerid"], true } return "", "", false } // canonicalizePodUID converts a Pod UID, as represented in a cgroup path, into
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 11K bytes - Viewed (0) -
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) -
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/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/volume/projected/projected.go
&projectedVolume{ volName: volName, podUID: podUID, plugin: plugin, MetricsProvider: volume.NewCachedMetrics(volume.NewMetricsDu(getPath(podUID, volName, plugin.host))), }, }, nil } func (plugin *projectedPlugin) ConstructVolumeSpec(volumeName, mountPath string) (volume.ReconstructedVolume, error) { projectedVolume := &v1.Volume{ Name: volumeName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 12.8K bytes - Viewed (0)