- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 27 for removeContainers (0.24 sec)
-
pkg/kubelet/cm/cpumanager/policy_none_test.go
} testPod := makePod("fakePod", "fakeContainer", "1000m", "1000m") container := &testPod.Spec.Containers[0] err := policy.RemoveContainer(st, string(testPod.UID), container.Name) if err != nil { t.Errorf("NonePolicy RemoveContainer() error. expected no error but got %v", err) } } func TestNonePolicyGetAllocatableCPUs(t *testing.T) { // any random topology is fine var cpuIDs []int
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.7K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager.go
AddContainer(p *v1.Pod, c *v1.Container, containerID string) // RemoveContainer is called after Kubelet decides to kill or delete a // container. After this call, the CPU manager stops trying to reconcile // that container and any CPUs dedicated to the container are freed. RemoveContainer(containerID string) error // State returns a read-only interface to the internal CPU manager state.
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/memorymanager/memory_manager.go
Allocate(pod *v1.Pod, container *v1.Container) error // RemoveContainer is called after Kubelet decides to kill or delete a // container. After this call, any memory allocated to the container is freed. RemoveContainer(containerID string) error // State returns a read-only interface to the internal memory manager state. State() state.Reader
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 00:50:45 UTC 2023 - 17.1K bytes - Viewed (1) -
pkg/kubelet/cm/internal_container_lifecycle.go
} i.topologyManager.AddContainer(pod, container, containerID) return nil } func (i *internalContainerLifecycleImpl) PostStopContainer(containerID string) error { return i.topologyManager.RemoveContainer(containerID)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 10 06:43:12 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_none.go
klog.InfoS("None policy: Start") return nil } func (p *nonePolicy) Allocate(s state.State, pod *v1.Pod, container *v1.Container) error { return nil } func (p *nonePolicy) RemoveContainer(s state.State, podUID string, containerName string) error { return nil } func (p *nonePolicy) GetTopologyHints(s state.State, pod *v1.Pod, container *v1.Container) map[string][]topologymanager.TopologyHint { return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_static_test.go
testCase.description, testCase.expCSetAfterAlloc, st.defaultCPUSet) } // remove policy.RemoveContainer(st, string(pod.UID), testCase.containerName) if !reflect.DeepEqual(st.defaultCPUSet, testCase.expCSetAfterRemove) { t.Errorf("StaticPolicy RemoveContainer() error (%v). expected default cpuset %v but got %v", testCase.description, testCase.expCSetAfterRemove, st.defaultCPUSet) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 40.8K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/instrumented_services.go
recordError(operation, err) return err } func (in instrumentedRuntimeService) RemoveContainer(ctx context.Context, containerID string) error { const operation = "remove_container" defer recordOperation(operation, time.Now()) err := in.service.RemoveContainer(ctx, containerID) recordError(operation, err) return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager_test.go
activePods: func() []*v1.Pod { return nil }, podStatusProvider: mockPodStatusProvider{}, } containerMap.Add("", "", containerID) err := mgr.RemoveContainer(containerID) if err != nil { t.Errorf("CPU Manager RemoveContainer() error. expected error to be nil but got: %v", err) } mgr = &manager{ policy: &mockPolicy{ err: fmt.Errorf("fake error"), },
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/kuberuntime/kuberuntime_container.go
} // prune all other init containers that match this container name klog.V(4).InfoS("Removing init container", "containerName", status.Name, "containerID", status.ID.ID, "count", count) if err := m.removeContainer(ctx, status.ID.ID); err != nil { utilruntime.HandleError(fmt.Errorf("failed to remove pod init container %q: %v; Skipping pod %q", status.Name, err, format.Pod(pod))) continue } } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/releases/upgrading/upgrading_version_7.adoc
finalizedBy("dockerStop") // dependsOn removeContainer } register("dockerUp") { dependsOn("createContainer") } register("dockerStop") { dependsOn("removeContainer") } register("createContainer") { mustRunAfter("removeContainer") }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 01 15:00:23 UTC 2024 - 87.7K bytes - Viewed (0)