- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for activePods (0.33 sec)
-
pkg/kubelet/cm/cpumanager/topology_hints_test.go
topology, _ := topology.Discover(&machineInfo) var activePods []*v1.Pod for p := range tc.assignments { pod := v1.Pod{} pod.UID = types.UID(p) for c := range tc.assignments[p] { container := v1.Container{} container.Name = c pod.Spec.Containers = append(pod.Spec.Containers, container) } activePods = append(activePods, &pod) } m := manager{ policy: &staticPolicy{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 19K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
expectedAllocatedResName1: 2, expectedAllocatedResName2: 2, expErr: nil, }, } activePods := []*v1.Pod{} for _, testCase := range testCases { pod := testCase.testPod activePods = append(activePods, pod) podsStub.updateActivePods(activePods) err := testManager.Allocate(pod, &pod.Spec.Containers[0]) if !reflect.DeepEqual(err, testCase.expErr) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager.go
} func (m *manager) Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady, podStatusProvider status.PodStatusProvider, containerRuntime runtimeService, initialContainers containermap.ContainerMap) error { klog.InfoS("Starting CPU manager", "policy", m.policy.Name()) klog.InfoS("Reconciling", "reconcilePeriod", m.reconcilePeriod) m.sourcesReady = sourcesReady m.activePods = activePods m.podStatusProvider = podStatusProvider
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/kubelet/cm/dra/manager.go
kubeClient: kubeClient, reconcilePeriod: reconcilePeriod, activePods: nil, sourcesReady: nil, } return manager, nil } // Start starts the reconcile loop of the manager. func (m *ManagerImpl) Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady) error { m.activePods = activePods m.sourcesReady = sourcesReady
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:29 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux_test.go
var tests = []struct { desc string activePods []*v1.Pod shutdownGracePeriodRequested time.Duration shutdownGracePeriodCriticalPods time.Duration systemInhibitDelay time.Duration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 29.8K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager_test.go
}, lastUpdateState: state.NewMemoryState(), containerRuntime: mockRuntimeService{ err: testCase.updateErr, }, containerMap: containermap.NewContainerMap(), activePods: func() []*v1.Pod { return testCase.activePods }, podStatusProvider: mockPodStatusProvider{ podStatus: testCase.pspPS, found: testCase.pspFound, }, } mgr.sourcesReady = &sourcesReadyStub{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 06 13:16:15 UTC 2023 - 42.9K bytes - Viewed (0) -
pkg/kubelet/cm/qos_container_manager_linux.go
Guaranteed: rootContainer, Burstable: qosClasses[v1.PodQOSBurstable], BestEffort: qosClasses[v1.PodQOSBestEffort], } m.getNodeAllocatable = getNodeAllocatable m.activePods = activePods // update qos cgroup tiers on startup and in periodic intervals // to ensure desired state is in sync with actual state. go wait.Until(func() { err := m.UpdateCgroups() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 20:42:59 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/controller/job/indexed_job_utils_test.go
activePods := controller.FilterActivePods(logger, tc.pods) failedIndexes := calculateFailedIndexes(logger, &tc.job, tc.pods) _, succeededIndexes := calculateSucceededIndexes(logger, &tc.job, tc.pods) jobCtx := &syncJobCtx{ job: &tc.job, pods: tc.pods, activePods: activePods, succeededIndexes: succeededIndexes,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 27.9K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/memory_manager.go
func (m *manager) Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady, podStatusProvider status.PodStatusProvider, containerRuntime runtimeService, initialContainers containermap.ContainerMap) error { klog.InfoS("Starting memorymanager", "policy", m.policy.Name()) m.sourcesReady = sourcesReady m.activePods = activePods m.podStatusProvider = podStatusProvider
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 00:50:45 UTC 2023 - 17.1K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/memory_manager_test.go
state: state.NewMemoryState(), containerMap: containermap.NewContainerMap(), containerRuntime: mockRuntimeService{ err: testCase.updateError, }, activePods: func() []*v1.Pod { return testCase.activePods }, podStatusProvider: mockPodStatusProvider{}, } mgr.sourcesReady = &sourcesReadyStub{} mgr.state.SetMachineState(testCase.machineState)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 05 13:01:40 UTC 2023 - 70.2K bytes - Viewed (0)