Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for removeContainers (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top