- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 94 for podAdd (0.09 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/config/file.go
"k8s.io/client-go/tools/cache" api "k8s.io/kubernetes/pkg/apis/core" kubetypes "k8s.io/kubernetes/pkg/kubelet/types" utilio "k8s.io/utils/io" ) type podEventType int const ( podAdd podEventType = iota podModify podDelete eventBufferLen = 10 ) type watchEvent struct { fileName string eventType podEventType } type sourceFile struct { path string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 01 07:19:44 UTC 2021 - 6.2K 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/memorymanager/state/state_mem.go
func (s *stateMemory) Delete(podUID string, containerName string) { s.Lock() defer s.Unlock() if _, ok := s.assignments[podUID]; !ok { return } delete(s.assignments[podUID], containerName) if len(s.assignments[podUID]) == 0 { delete(s.assignments, podUID) } klog.V(2).InfoS("Deleted memory assignment", "podUID", podUID, "containerName", containerName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 15 19:51:19 UTC 2021 - 3.2K 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_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 { scope := scope{} actual := scope.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 - 3.3K 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)