Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 70 for podStates (0.13 sec)

  1. pkg/kubelet/pleg/evented_test.go

    kubelet_running_pods 5
    `
    	testMetric(t, expectedMetric, metrics.RunningPodCount.FQName())
    
    	// stop sandbox containers for first 2 pods
    	for _, podStatus := range podStatuses[:2] {
    		podId := string(podStatus.ID)
    		newPodStatus := kubecontainer.PodStatus{
    			ID: podStatus.ID,
    			SandboxStatuses: []*v1.PodSandboxStatus{
    				{Id: podId},
    			},
    			ContainerStatuses: []*kubecontainer.Status{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 01 07:45:05 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  2. pkg/util/pod/pod_test.go

    		description        string
    		mutate             func(input v1.PodStatus) v1.PodStatus
    		expectUnchanged    bool
    		expectedPatchBytes []byte
    	}{
    		{
    			"no change",
    			func(input v1.PodStatus) v1.PodStatus { return input },
    			true,
    			[]byte(fmt.Sprintf(`{"metadata":{"uid":"myuid"}}`)),
    		},
    		{
    			"message change",
    			func(input v1.PodStatus) v1.PodStatus {
    				input.Message = "random message"
    				return input
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 07 15:22:29 UTC 2022
    - 4.5K bytes
    - Viewed (0)
  3. pkg/kubelet/container/cache.go

    // and the blocking GetNewerThan() method. The component responsible for
    // populating the cache is expected to call Delete() to explicitly free the
    // cache entries.
    type Cache interface {
    	Get(types.UID) (*PodStatus, error)
    	// Set updates the cache by setting the PodStatus for the pod only
    	// if the data is newer than the cache based on the provided
    	// time stamp. Returns if the cache was updated.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 07:37:01 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  4. pkg/kubelet/metrics/collectors/log_metrics.go

    	return &logMetricsCollector{
    		podStats: podStats,
    	}
    }
    
    // DescribeWithStability implements the metrics.StableCollector interface.
    func (c *logMetricsCollector) DescribeWithStability(ch chan<- *metrics.Desc) {
    	ch <- descLogSize
    }
    
    // CollectWithStability implements the metrics.StableCollector interface.
    func (c *logMetricsCollector) CollectWithStability(ch chan<- metrics.Metric) {
    	podStats, err := c.podStats(context.Background())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 05 13:02:13 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  5. pkg/kubelet/pod_container_deletor.go

    func getContainersToDeleteInPod(filterContainerID string, podStatus *kubecontainer.PodStatus, containersToKeep int) containerStatusbyCreatedList {
    	matchedContainer := func(filterContainerId string, podStatus *kubecontainer.PodStatus) *kubecontainer.Status {
    		if filterContainerId == "" {
    			return nil
    		}
    		for _, containerStatus := range podStatus.ContainerStatuses {
    			if containerStatus.ID.ID == filterContainerId {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 05 13:02:13 UTC 2022
    - 4K bytes
    - Viewed (0)
  6. pkg/kubelet/kuberuntime/util/util_test.go

    	for desc, test := range map[string]struct {
    		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)
  7. pkg/kubelet/prober/testing/fake_manager.go

    // Start simulates start syncing the probe status
    func (FakeManager) Start() {}
    
    // UpdatePodStatus simulates updating the Pod Status.
    func (FakeManager) UpdatePodStatus(_ *v1.Pod, podStatus *v1.PodStatus) {
    	for i := range podStatus.ContainerStatuses {
    		podStatus.ContainerStatuses[i].Ready = true
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 07 22:26:12 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  8. pkg/kubelet/metrics/collectors/log_metrics_test.go

    func TestNoMetricsCollected(t *testing.T) {
    	// Refresh Desc to share with different registry
    	descLogSize = descLogSize.GetRawDesc()
    
    	collector := &logMetricsCollector{
    		podStats: func(_ context.Context) ([]statsapi.PodStats, error) {
    			return []statsapi.PodStats{}, nil
    		},
    	}
    
    	if err := testutil.CustomCollectAndCompare(collector, strings.NewReader(""), ""); err != nil {
    		t.Fatal(err)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 05 13:02:13 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  9. pkg/controller/job/pod_failure_policy.go

    func matchOnExitCodes(podStatus *v1.PodStatus, requirement *batch.PodFailurePolicyOnExitCodesRequirement) *v1.ContainerStatus {
    	if containerStatus := getMatchingContainerFromList(podStatus.ContainerStatuses, requirement); containerStatus != nil {
    		return containerStatus
    	}
    	return getMatchingContainerFromList(podStatus.InitContainerStatuses, requirement)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 20:44:11 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  10. pkg/kubelet/stats/cri_stats_provider_others.go

    }
    
    func addCRIPodCPUStats(ps *statsapi.PodStats, criPodStat *runtimeapi.PodSandboxStats) {
    }
    
    func addCRIPodProcessStats(ps *statsapi.PodStats, criPodStat *runtimeapi.PodSandboxStats) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 16 11:09:04 UTC 2023
    - 1.8K bytes
    - Viewed (0)
Back to top