Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ListPodSandbox (0.23 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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