- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for removeContainers (0.26 sec)
-
cmd/kubeadm/app/cmd/phases/reset/cleanupnode.go
} } return nil } func removeContainers(criSocketPath string) error { containerRuntime := utilruntime.NewContainerRuntime(criSocketPath) if err := containerRuntime.Connect(); err != nil { return err } containers, err := containerRuntime.ListKubeContainers() if err != nil { return err } return containerRuntime.RemoveContainers(containers) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 06:58:01 UTC 2024 - 7.1K bytes - Viewed (0) -
cmd/kubeadm/app/util/runtime/runtime.go
} pods := []string{} for _, sandbox := range sandboxes { pods = append(pods, sandbox.GetId()) } return pods, nil } // RemoveContainers removes running k8s pods func (runtime *CRIRuntime) RemoveContainers(containers []string) error { errs := []error{} for _, container := range containers { var lastErr error for i := 0; i < constants.RemoveContainerRetry; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 06:33:22 UTC 2024 - 8.4K bytes - Viewed (0) -
cmd/kubeadm/app/util/runtime/runtime_test.go
containerRuntime := NewContainerRuntime("") mock := &fakeImpl{} if tc.prepare != nil { tc.prepare(mock) } containerRuntime.SetImpl(mock) err := containerRuntime.RemoveContainers(tc.containers) assert.Equal(t, tc.shouldError, err != nil) }) } } func TestPullImage(t *testing.T) { for _, tc := range []struct { name string prepare func(*fakeImpl)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 06:33:22 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy.go
type Policy interface { Name() string Start(s state.State) error // Allocate call is idempotent Allocate(s state.State, pod *v1.Pod, container *v1.Container) error // RemoveContainer call is idempotent RemoveContainer(s state.State, podUID string, containerName string) // GetTopologyHints implements the topologymanager.HintProvider Interface // and is consulted to achieve NUMA aware resource alignment among this
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 05 17:52:25 UTC 2021 - 1.8K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope.go
AddHintProvider(h HintProvider) // AddContainer adds pod to Manager for tracking AddContainer(pod *v1.Pod, container *v1.Container, containerID string) // RemoveContainer removes pod from Manager tracking RemoveContainer(containerID string) error // Store is the interface for storing pod topology hints Store } type scope struct { mutex sync.Mutex name string
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/cm/memorymanager/fake_memory_manager.go
klog.InfoS("Get MemoryNUMANodes", "pod", klog.KObj(pod), "containerName", container.Name) return nil } func (m *fakeManager) RemoveContainer(containerID string) error { klog.InfoS("RemoveContainer", "containerID", containerID) return nil } func (m *fakeManager) GetTopologyHints(pod *v1.Pod, container *v1.Container) map[string][]topologymanager.TopologyHint {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 3.1K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/topology_manager.go
AddHintProvider(HintProvider) // AddContainer adds pod to Manager for tracking AddContainer(pod *v1.Pod, container *v1.Container, containerID string) // RemoveContainer removes pod from Manager tracking RemoveContainer(containerID string) error // Store is the interface for storing pod topology hints Store } type manager struct { //Topology Manager Scope scope Scope }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 15 12:43:16 UTC 2023 - 7.6K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy_none.go
return nil } // Allocate call is idempotent func (p *none) Allocate(s state.State, pod *v1.Pod, container *v1.Container) error { return nil } // RemoveContainer call is idempotent func (p *none) RemoveContainer(s state.State, podUID string, containerName string) { } // GetTopologyHints implements the topologymanager.HintProvider Interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 05 17:52:25 UTC 2021 - 2.2K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/fake_topology_manager.go
klog.InfoS("AddContainer", "pod", klog.KObj(pod), "containerName", container.Name, "containerID", containerID) } func (m *fakeManager) RemoveContainer(containerID string) error { klog.InfoS("RemoveContainer", "containerID", containerID) return nil } func (m *fakeManager) Admit(attrs *lifecycle.PodAdmitAttributes) lifecycle.PodAdmitResult { klog.InfoS("Topology Admit Handler")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 02 18:02:07 UTC 2022 - 2.3K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy.go
type Policy interface { Name() string Start(s state.State) error // Allocate call is idempotent Allocate(s state.State, pod *v1.Pod, container *v1.Container) error // RemoveContainer call is idempotent RemoveContainer(s state.State, podUID string, containerName string) error // GetTopologyHints implements the topologymanager.HintProvider Interface // and is consulted to achieve NUMA aware resource alignment among this
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 1.8K bytes - Viewed (0)