- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for Statuses (0.14 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)