- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 79 for podAdd (0.23 sec)
-
pkg/kubelet/config/file_linux.go
klog.V(4).InfoS("Ignored pod manifest, because it starts with dots", "eventName", e.Name) return nil } var eventType podEventType switch { case (e.Op & fsnotify.Create) > 0: eventType = podAdd case (e.Op & fsnotify.Write) > 0: eventType = podModify case (e.Op & fsnotify.Chmod) > 0: eventType = podModify case (e.Op & fsnotify.Remove) > 0: eventType = podDelete
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 17:27:26 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/scheduler/internal/queue/events.go
limitations under the License. */ package queue import ( "k8s.io/kubernetes/pkg/scheduler/framework" ) const ( // PodAdd is the event when a new pod is added to API server. PodAdd = "PodAdd" // ScheduleAttemptFailure is the event when a schedule attempt fails. ScheduleAttemptFailure = "ScheduleAttemptFailure" // BackoffComplete is the event when a pod finishes backoff.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/kubelet/status/state/state_mem.go
} func (s *stateMemory) deleteContainer(podUID string, containerName string) { delete(s.podAllocation[podUID], containerName) if len(s.podAllocation[podUID]) == 0 { delete(s.podAllocation, podUID) delete(s.podResizeStatus, podUID) } klog.V(3).InfoS("Deleted pod resource allocation", "podUID", podUID, "containerName", containerName) } func (s *stateMemory) Delete(podUID string, containerName string) error { s.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 24 18:21:21 UTC 2023 - 4K bytes - Viewed (0) -
pkg/kubelet/cm/containermap/container_map.go
containerName string }{podUID, containerName} } // RemoveByContainerID removes a mapping of (containerID)->(podUID, containerName) from the ContainerMap func (cm ContainerMap) RemoveByContainerID(containerID string) { delete(cm, containerID) } // RemoveByContainerRef removes a mapping of (containerID)->(podUID, containerName) from the ContainerMap func (cm ContainerMap) RemoveByContainerRef(podUID, containerName string) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 30 15:25:05 UTC 2022 - 2.5K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/state/state_mem.go
klog.InfoS("Updated CPUSet assignments", "assignments", a) } func (s *stateMemory) Delete(podUID string, containerName string) { s.Lock() defer s.Unlock() delete(s.assignments[podUID], containerName) if len(s.assignments[podUID]) == 0 { delete(s.assignments, podUID) } klog.V(2).InfoS("Deleted CPUSet assignment", "podUID", podUID, "containerName", containerName) } func (s *stateMemory) ClearState() { s.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kubelet/cm/containermap/container_map_test.go
} if podUID != tc.podUID { t.Errorf("mismatched pod UID %v, %v", tc.podUID, podUID) } if containerName != tc.containerNames[i] { t.Errorf("mismatched container Name %v, %v", tc.containerNames[i], containerName) } } // Remove all entries from the containerMap, checking proper removal of // each along the way. cm.Visit(func(podUID string, containerName string, containerID string) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 02 13:40:55 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope.go
} func (s *scope) getTopologyHints(podUID string, containerName string) TopologyHint { s.mutex.Lock() defer s.mutex.Unlock() return s.podTopologyHints[podUID][containerName] } func (s *scope) setTopologyHints(podUID string, containerName string, th TopologyHint) { s.mutex.Lock() defer s.mutex.Unlock() if s.podTopologyHints[podUID] == nil { s.podTopologyHints[podUID] = make(map[string]TopologyHint) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 5K bytes - Viewed (0) -
pkg/kubelet/userns/userns_manager_switch_test.go
require.NoError(t, err) for _, podUID := range pods { pod := v1.Pod{ObjectMeta: metav1.ObjectMeta{UID: podUID}} userns, err := m2.GetOrCreateUserNamespaceMappings(&pod, "") assert.NoError(t, err, "failed to record userns range for pod %v", podUID) assert.Nil(t, userns, "userns range should be nil for pod %v", podUID) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 5K bytes - Viewed (0) -
pkg/kubelet/status/state/state_checkpoint.go
// GetContainerResourceAllocation returns current resources allocated to a pod's container func (sc *stateCheckpoint) GetContainerResourceAllocation(podUID string, containerName string) (v1.ResourceList, bool) { sc.mux.RLock() defer sc.mux.RUnlock() return sc.cache.GetContainerResourceAllocation(podUID, containerName) } // GetPodResourceAllocation returns current pod resource allocation
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 13 00:16:44 UTC 2023 - 6.9K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/fake_cpu_manager.go
return m.state } func (m *fakeManager) GetExclusiveCPUs(podUID, containerName string) cpuset.CPUSet { klog.InfoS("GetExclusiveCPUs", "podUID", podUID, "containerName", containerName) return cpuset.CPUSet{} } func (m *fakeManager) GetAllocatableCPUs() cpuset.CPUSet { klog.InfoS("Get Allocatable CPUs") return cpuset.CPUSet{} } func (m *fakeManager) GetCPUAffinity(podUID, containerName string) cpuset.CPUSet {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.9K bytes - Viewed (0)