Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 23 for Sandboxes (0.13 sec)

  1. pkg/kubelet/kuberuntime/util/util_test.go

    		pod               *v1.Pod
    		status            *kubecontainer.PodStatus
    		expectedChanged   bool
    		expectedAttempt   uint32
    		expectedSandboxID string
    	}{
    		"Pod with no existing sandboxes": {
    			pod:               &v1.Pod{},
    			status:            &kubecontainer.PodStatus{},
    			expectedChanged:   true,
    			expectedAttempt:   0,
    			expectedSandboxID: "",
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 13 23:14:48 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  2. pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

    		})
    	}
    	podSandBoxStatus.Network.AdditionalIps = additionalPodIPs
    	return podSandBoxStatus
    
    }
    
    // makeFakePodSandboxes creates a group of fake pod sandboxes based on the sandbox templates.
    // The function guarantees the order of the fake pod sandboxes is the same with the templates.
    func makeFakePodSandboxes(t *testing.T, m *kubeGenericRuntimeManager, templates []sandboxTemplate) []*apitest.FakePodSandbox {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
  3. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    func (m *kubeGenericRuntimeManager) GetPods(ctx context.Context, all bool) ([]*kubecontainer.Pod, error) {
    	pods := make(map[kubetypes.UID]*kubecontainer.Pod)
    	sandboxes, err := m.getKubeletSandboxes(ctx, all)
    	if err != nil {
    		return nil, err
    	}
    	for i := range sandboxes {
    		s := sandboxes[i]
    		if s.Metadata == nil {
    			klog.V(4).InfoS("Sandbox does not have metadata", "sandbox", s)
    			continue
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  4. pkg/kubelet/kuberuntime/helpers.go

    		State:               toKubeContainerState(c.State),
    	}, nil
    }
    
    // sandboxToKubeContainer converts runtimeapi.PodSandbox to kubecontainer.Container.
    // This is only needed because we need to return sandboxes as if they were
    // kubecontainer.Containers to avoid substantial changes to PLEG.
    // TODO: Remove this once it becomes obsolete.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 12K bytes
    - Viewed (0)
  5. pkg/kubelet/pleg/evented.go

    		if sandboxStatus.State == runtimeapi.PodSandboxState_SANDBOX_READY {
    			return status.IPs
    		}
    	}
    
    	// For pods with no ready containers or sandboxes (like exited pods)
    	// use the old status' pod IP
    	return oldStatus.IPs
    }
    
    func (e *EventedPLEG) sendPodLifecycleEvent(event *PodLifecycleEvent) {
    	select {
    	case e.eventChannel <- event:
    	default:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 10:46:06 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  6. pkg/kubelet/metrics/metrics.go

    			Help:           "Cumulative number of pods started",
    			StabilityLevel: metrics.ALPHA,
    		},
    	)
    	// StartedPodsErrorsTotal is a counter that tracks the number of errors creating pod sandboxes
    	StartedPodsErrorsTotal = metrics.NewCounter(
    		&metrics.CounterOpts{
    			Subsystem:      KubeletSubsystem,
    			Name:           StartedPodsErrorsTotalKey,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 15:13:25 UTC 2024
    - 45.6K bytes
    - Viewed (0)
  7. pkg/kubelet/stats/cri_stats_provider.go

    	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 {
    		podSandboxMap[s.Id] = s
    	}
    
    	containers = removeTerminatedContainers(containers)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 35.1K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_pods.go

    }
    
    // killPod instructs the container runtime to kill the pod. This method requires that
    // the pod status contains the result of the last syncPod, otherwise it may fail to
    // terminate newly created containers and sandboxes.
    func (kl *Kubelet) killPod(ctx context.Context, pod *v1.Pod, p kubecontainer.Pod, gracePeriodOverride *int64) error {
    	// Call the container runtime KillPod method which stops all known running containers of the pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  9. tools/istio-iptables/pkg/dependencies/implementation_linux_test.go

    	original := file.AsStringOrFail(t, "/etc/nsswitch.conf")
    	var sandboxed string
    
    	originalNetNS, err := netns.Get()
    	assert.NoError(t, err)
    	var sandboxedNetNS netns.NsHandle
    
    	// Due to unshare-go imports above, this can run
    	assert.NoError(t, runInSandbox("", func() error {
    		// We should have overwritten this file with /dev/null
    		sandboxed = file.AsStringOrFail(t, "/etc/nsswitch.conf")
    		sandboxedNetNS, err = netns.Get()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Feb 26 20:05:40 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  10. pkg/kubelet/kubelet.go

    func (kl *Kubelet) ListMetricDescriptors(ctx context.Context) ([]*runtimeapi.MetricDescriptor, error) {
    	return kl.containerRuntime.ListMetricDescriptors(ctx)
    }
    
    // ListPodSandboxMetrics retrieves the metrics for all pod sandboxes.
    func (kl *Kubelet) ListPodSandboxMetrics(ctx context.Context) ([]*runtimeapi.PodSandboxMetrics, error) {
    	return kl.containerRuntime.ListPodSandboxMetrics(ctx)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
Back to top