- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for ListPodSandbox (0.33 sec)
-
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) -
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) -
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) -
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) -
pkg/kubelet/kuberuntime/kuberuntime_sandbox.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 13.6K bytes - Viewed (0) -
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) -
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) -
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) -
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)