- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 261 for pvcuid (0.11 sec)
-
pkg/kubelet/pod_workers.go
// UpdatePod. func (p *podWorkers) completeSync(podUID types.UID) { p.podLock.Lock() defer p.podLock.Unlock() klog.V(4).InfoS("Pod indicated lifecycle completed naturally and should now terminate", "podUID", podUID) status, ok := p.podSyncStatuses[podUID] if !ok { klog.V(4).InfoS("Pod had no status in completeSync, programmer error?", "podUID", podUID) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/kubelet/status/fake_status_manager.go
klog.InfoS("RemoveOrphanedStatuses()") return } func (m *fakeManager) GetContainerResourceAllocation(podUID string, containerName string) (v1.ResourceList, bool) { klog.InfoS("GetContainerResourceAllocation()") return m.state.GetContainerResourceAllocation(podUID, containerName) } func (m *fakeManager) GetPodResizeStatus(podUID string) (v1.PodResizeStatus, bool) { klog.InfoS("GetPodResizeStatus()") return "", false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 05:59:34 UTC 2023 - 2.7K bytes - Viewed (0) -
pkg/kubelet/stats/host_stats_provider.go
} func (h hostStatsProvider) podLogMetrics(podNamespace, podName string, podUID types.UID) (metricsProviderByPath, error) { podLogsDirectoryPath := kuberuntime.BuildPodLogsDirectory(h.podLogsDirectory, podNamespace, podName, podUID) return h.fileMetricsByDir(podLogsDirectoryPath) } func (h hostStatsProvider) podContainerLogMetrics(podNamespace, podName string, podUID types.UID, containerName string) (metricsProviderByPath, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 17:55:59 UTC 2024 - 6.6K bytes - Viewed (0) -
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/kubelet/status/state/state.go
type Reader interface { GetContainerResourceAllocation(podUID string, containerName string) (v1.ResourceList, bool) GetPodResourceAllocation() PodResourceAllocation GetPodResizeStatus(podUID string) (v1.PodResizeStatus, bool) GetResizeStatus() PodResizeStatus } type writer interface { SetContainerResourceAllocation(podUID string, containerName string, alloc v1.ResourceList) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 24 18:21:21 UTC 2023 - 2K 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 (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/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/cm/cpumanager/state/state.go
// Reader interface used to read current cpu/pod assignment state type Reader interface { GetCPUSet(podUID string, containerName string) (cpuset.CPUSet, bool) GetDefaultCPUSet() cpuset.CPUSet GetCPUSetOrDefault(podUID string, containerName string) cpuset.CPUSet GetCPUAssignments() ContainerCPUAssignments } type writer interface { SetCPUSet(podUID string, containerName string, cpuset cpuset.CPUSet) SetDefaultCPUSet(cpuset cpuset.CPUSet)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 00:59:30 UTC 2023 - 1.7K bytes - Viewed (0)