- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 90 for pvcuid (0.13 sec)
-
pkg/controller/volume/expand/expand_controller_test.go
Namespace: "default", }, Capacity: map[v1.ResourceName]resource.Quantity{ v1.ResourceStorage: resource.MustParse(size), }, }, } if pvcUID != "" { pv.Spec.ClaimRef.UID = pvcUID } if matched, _ := regexp.MatchString(`csi`, pluginName); matched { pv.Spec.PersistentVolumeSource.CSI = &v1.CSIPersistentVolumeSource{ Driver: pluginName, VolumeHandle: volumeName, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 7.9K 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/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) -
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)