Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for ListPodSandbox (0.32 sec)

  1. cmd/kubeadm/app/util/runtime/impl.go

    	return runtimeService.Status(ctx, verbose)
    }
    
    func (*defaultImpl) ListPodSandbox(ctx context.Context, runtimeService criapi.RuntimeService, filter *runtimeapi.PodSandboxFilter) ([]*runtimeapi.PodSandbox, error) {
    	return runtimeService.ListPodSandbox(ctx, filter)
    }
    
    func (*defaultImpl) StopPodSandbox(ctx context.Context, runtimeService criapi.RuntimeService, sandboxID string) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 06:58:01 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/helpers.go

    func buildContainerMapAndRunningSetFromRuntime(ctx context.Context, runtimeService internalapi.RuntimeService) (containermap.ContainerMap, sets.Set[string]) {
    	podSandboxMap := make(map[string]string)
    	podSandboxList, _ := runtimeService.ListPodSandbox(ctx, nil)
    	for _, p := range podSandboxList {
    		podSandboxMap[p.Id] = p.Metadata.Uid
    	}
    
    	runningSet := sets.New[string]()
    	containerMap := containermap.NewContainerMap()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/util/runtime/runtime_fake_test.go

    }
    
    func (fake *fakeImpl) ImageStatusReturns(res *v1.ImageStatusResponse, err error) {
    	fake.imageStatusReturns = struct {
    		res *v1.ImageStatusResponse
    		err error
    	}{res, err}
    }
    
    func (fake *fakeImpl) ListPodSandbox(context.Context, cri.RuntimeService, *v1.PodSandboxFilter) ([]*v1.PodSandbox, error) {
    	fakeReturns := fake.listPodSandboxReturns
    	return fakeReturns.res, fakeReturns.err
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 06:58:01 UTC 2024
    - 4K bytes
    - Viewed (0)
  4. pkg/kubelet/kuberuntime/instrumented_services.go

    	recordError(operation, err)
    	return out, err
    }
    
    func (in instrumentedRuntimeService) ListPodSandbox(ctx context.Context, filter *runtimeapi.PodSandboxFilter) ([]*runtimeapi.PodSandbox, error) {
    	const operation = "list_podsandbox"
    	defer recordOperation(operation, time.Now())
    
    	out, err := in.service.ListPodSandbox(ctx, filter)
    	recordError(operation, err)
    	return out, 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)
  5. pkg/kubelet/kuberuntime/kuberuntime_sandbox.go

    		filter = &runtimeapi.PodSandboxFilter{
    			State: &runtimeapi.PodSandboxStateValue{
    				State: readyState,
    			},
    		}
    	}
    
    	resp, err := m.runtimeService.ListPodSandbox(ctx, filter)
    	if err != nil {
    		klog.ErrorS(err, "Failed to list pod sandboxes")
    		return nil, err
    	}
    
    	return resp, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/util/runtime/runtime.go

    }
    
    // ListKubeContainers lists running k8s CRI pods
    func (runtime *CRIRuntime) ListKubeContainers() ([]string, error) {
    	ctx, cancel := defaultContext()
    	defer cancel()
    
    	sandboxes, err := runtime.impl.ListPodSandbox(ctx, runtime.runtimeService, nil)
    	if err != nil {
    		return nil, errors.Wrap(err, "failed to list pod sandboxes")
    	}
    
    	pods := []string{}
    	for _, sandbox := range sandboxes {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 06:33:22 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. pkg/kubelet/kuberuntime/kuberuntime_sandbox_test.go

    		assert.Equal(t, os.FileMode(0755), perm)
    		return nil
    	}
    	id, _, err := m.createPodSandbox(ctx, pod, 1)
    	assert.NoError(t, err)
    	assert.Contains(t, fakeRuntime.Called, "RunPodSandbox")
    	sandboxes, err := fakeRuntime.ListPodSandbox(ctx, &runtimeapi.PodSandboxFilter{Id: id})
    	assert.NoError(t, err)
    	assert.Equal(t, len(sandboxes), 1)
    	assert.Equal(t, sandboxes[0].Id, fmt.Sprintf("%s_%s_%s_1", pod.Name, pod.Namespace, pod.UID))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  8. pkg/kubelet/kuberuntime/kuberuntime_gc_test.go

    			fakeRuntime.SetFakeContainers(fakeContainers)
    
    			err := m.containerGC.evictSandboxes(ctx, test.evictTerminatingPods)
    			assert.NoError(t, err)
    			realRemain, err := fakeRuntime.ListPodSandbox(ctx, nil)
    			assert.NoError(t, err)
    			assert.Len(t, realRemain, len(test.remain))
    			for _, remain := range test.remain {
    				resp, err := fakeRuntime.PodSandboxStatus(ctx, fakeSandboxes[remain].Id, false)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  9. pkg/kubelet/stats/cri_stats_provider.go

    	}
    
    	// Creates pod sandbox map between the pod sandbox ID and the PodSandbox object.
    	podSandboxMap := make(map[string]*runtimeapi.PodSandbox)
    	podSandboxes, err := p.runtimeService.ListPodSandbox(ctx, &runtimeapi.PodSandboxFilter{})
    	if err != nil {
    		return nil, nil, fmt.Errorf("failed to list all pod sandboxes: %v", err)
    	}
    	podSandboxes = removeTerminatedPods(podSandboxes)
    	for _, s := range podSandboxes {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 35.1K bytes
    - Viewed (0)
Back to top