Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for Statuses (0.14 sec)

  1. pkg/printers/internalversion/printers.go

    				current := "<unknown>"
    				if len(statuses) > i && statuses[i].External != nil && statuses[i].External.Current.AverageValue != nil {
    					current = statuses[i].External.Current.AverageValue.String()
    				}
    				list = append(list, fmt.Sprintf("%s/%s (avg)", current, spec.External.Target.AverageValue.String()))
    			} else {
    				current := "<unknown>"
    				if len(statuses) > i && statuses[i].External != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_test.go

    		cStatus := &kubecontainer.Status{
    			ID:   kubecontainer.BuildContainerID("test", id),
    			Name: containerName,
    		}
    		// Rearrange container statuses
    		if i%2 == 0 {
    			cStatuses = append(cStatuses, cStatus)
    		} else {
    			cStatuses = append([]*kubecontainer.Status{cStatus}, cStatuses...)
    		}
    		specContainerList = append(specContainerList, v1.Container{Name: containerName})
    	}
    	pod := podWithUIDNameNs("uid1", "foo", "test")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_pods.go

    				Message: reason.Message,
    			},
    		}
    		statuses[container.Name] = status
    	}
    
    	// Sort the container statuses since clients of this interface expect the list
    	// of containers in a pod has a deterministic order.
    	if isInitContainer {
    		return kubetypes.SortStatusesOfInitContainers(pod, statuses)
    	}
    	containerStatuses := make([]v1.ContainerStatus, 0, len(statuses))
    	for _, status := range statuses {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  4. cmd/bucket-replication-utils.go

    	ResetStatusesMap           map[string]string                 // map of ARN-> stringified reset id and timestamp for all the targets
    }
    
    // Equal returns true if replication state is identical for version purge statuses and (replica)tion statuses.
    func (rs *ReplicationState) Equal(o ReplicationState) bool {
    	return rs.ReplicaStatus == o.ReplicaStatus &&
    		rs.ReplicationStatusInternal == o.ReplicationStatusInternal &&
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  5. pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

    				InitContainersToStart:    []int{0},
    				ContainersToStart:        []int{},
    				ContainersToKill:         getKillMapWithInitContainers(basePod, baseStatus, []int{}),
    			},
    		},
    		"some of the init container statuses are missing but the last init container is running, don't restart preceding ones": {
    			mutatePodFn: func(pod *v1.Pod) { pod.Spec.RestartPolicy = v1.RestartPolicyAlways },
    			mutateStatusFn: func(status *kubecontainer.PodStatus) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
  6. pilot/pkg/networking/core/cluster.go

    				// DRAINING/UNHEALTHY will not be used normally for new requests. They will be used if cookie/header
    				// selects them.
    				defaultCluster.cluster.CommonLbConfig.OverrideHostStatus = &core.HealthStatusSet{
    					Statuses: []core.HealthStatus{
    						core.HealthStatus_HEALTHY,
    						core.HealthStatus_DRAINING, core.HealthStatus_UNKNOWN, core.HealthStatus_DEGRADED,
    					},
    				}
    			}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/types.go

    	// if they're rejected in PreFilter (via PreFilterResult) or Filter plugins.
    	// Nodes that pass PreFilter/Filter plugins are not included in this map.
    	// While this map may contain UnschedulableAndUnresolvable statuses, the absence of
    	// a node should be interpreted as UnschedulableAndUnresolvable.
    	NodeToStatusMap NodeToStatusMap
    	// UnschedulablePlugins are plugins that returns Unschedulable or UnschedulableAndUnresolvable.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet.go

    	// it later). Set the status and phase appropriately
    	runnable := kl.canRunPod(pod)
    	if !runnable.Admit {
    		// Pod is not runnable; and update the Pod and Container statuses to why.
    		if apiPodStatus.Phase != v1.PodFailed && apiPodStatus.Phase != v1.PodSucceeded {
    			apiPodStatus.Phase = v1.PodPending
    		}
    		apiPodStatus.Reason = runnable.Reason
    		apiPodStatus.Message = runnable.Message
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  9. cmd/bucket-replication.go

    		if duration < time.Second {
    			// Make sure to sleep at least a second to avoid high CPU ticks.
    			duration = time.Second
    		}
    		time.Sleep(duration)
    	}
    }
    
    // Loads bucket replication resync statuses into memory.
    func (p *ReplicationPool) loadResync(ctx context.Context, buckets []BucketInfo, objAPI ObjectLayer) error {
    	// Make sure only one node running resync on the cluster.
    	ctx, cancel := globalLeaderLock.GetLock(ctx)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 114.4K bytes
    - Viewed (0)
  10. pkg/printers/internalversion/printers_test.go

    						{Type: metav1.RowCompleted, Status: metav1.ConditionTrue, Reason: "Succeeded", Message: "The pod has completed successfully."},
    					},
    				},
    			},
    		},
    		{
    			// Test pod has container statuses for non-existent initContainers and containers
    			api.Pod{
    				ObjectMeta: metav1.ObjectMeta{Name: "test4"},
    				Spec: api.PodSpec{
    					InitContainers: []api.Container{
    						{Name: "init1", Image: "initimage"},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 218.6K bytes
    - Viewed (0)
Back to top