- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 47 for Statuses (0.14 sec)
-
pkg/api/v1/pod/util.go
} } return true } // GetContainerStatus extracts the status of container "name" from "statuses". // It returns true if "name" exists, else returns false. func GetContainerStatus(statuses []v1.ContainerStatus, name string) (v1.ContainerStatus, bool) { for i := range statuses { if statuses[i].Name == name { return statuses[i], true } } return v1.ContainerStatus{}, false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 24 17:18:04 UTC 2023 - 13.2K bytes - Viewed (0) -
pkg/kubelet/pleg/generic_test.go
} event := &PodLifecycleEvent{ID: pod.ID, Type: ContainerStarted, Data: container.ID.ID} pods = append(pods, pod) statuses = append(statuses, status) events = append(events, event) } return pods, statuses, events } func TestRelistWithCache(t *testing.T) { ctx := context.Background() mockCtrl := gomock.NewController(t) defer mockCtrl.Finish()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 24.8K bytes - Viewed (0) -
cluster/gce/windows/smoke-test.sh
windows_deployment_timeout=600 output_file=/tmp/k8s-smoke-test.out function check_windows_nodes_are_ready { # kubectl filtering is the worst. statuses=$(${kubectl} get nodes -l kubernetes.io/os=windows \ -o jsonpath='{.items[*].status.conditions[?(@.type=="Ready")].status}') for status in $statuses; do if [[ $status == "False" ]]; then echo "ERROR: some Windows node has status != Ready"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 07:02:51 UTC 2024 - 20.6K bytes - Viewed (0) -
pkg/kubelet/status/status_manager.go
go wait.Forever(func() { for { select { case <-m.podStatusChannel: klog.V(4).InfoS("Syncing updated statuses") m.syncBatch(false) case <-syncTicker: klog.V(4).InfoS("Syncing all statuses") m.syncBatch(true) } } }, 0) } // GetContainerResourceAllocation returns the last checkpointed AllocatedResources values
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 44.3K bytes - Viewed (0) -
pkg/kubelet/container/helpers.go
func HasAnyRegularContainerStarted(spec *v1.PodSpec, statuses []v1.ContainerStatus) bool { if len(statuses) == 0 { return false } containerNames := make(map[string]struct{}) for _, c := range spec.Containers { containerNames[c.Name] = struct{}{} } for _, status := range statuses { if _, ok := containerNames[status.Name]; !ok { continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
} for failedNodeName, failedMsg := range failedAndUnresolvableMap { var aggregatedReasons []string if _, found := statuses[failedNodeName]; found { aggregatedReasons = statuses[failedNodeName].Reasons() } aggregatedReasons = append(aggregatedReasons, failedMsg) statuses[failedNodeName] = framework.NewStatus(framework.UnschedulableAndUnresolvable, aggregatedReasons...) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K 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/apis/core/fuzzer/fuzzer.go
func(s *core.PodStatus, c fuzz.Continue) { c.Fuzz(&s) s.HostIPs = []core.HostIP{{IP: s.HostIP}} }, func(j *core.PodPhase, c fuzz.Continue) { statuses := []core.PodPhase{core.PodPending, core.PodRunning, core.PodFailed, core.PodUnknown} *j = statuses[c.Rand.Intn(len(statuses))] }, func(j *core.Binding, c fuzz.Continue) { c.Fuzz(&j.ObjectMeta) j.Target.Name = c.RandString() },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 04:32:01 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/apis/core/v1/conversion.go
"pod.beta.kubernetes.io/init-containers": true, "pod.alpha.kubernetes.io/init-containers": true, "pod.beta.kubernetes.io/init-container-statuses": true, "pod.alpha.kubernetes.io/init-container-statuses": true, } // dropInitContainerAnnotations returns a copy of the annotations with init container annotations removed,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 22:30:55 UTC 2024 - 19K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
type NodeScoreList []NodeScore // NodeScore is a struct with node name and score. type NodeScore struct { Name string Score int64 } // NodeToStatusMap contains the statuses of the Nodes where the incoming Pod was not schedulable. // A PostFilter plugin that uses this map should interpret absent Nodes as UnschedulableAndUnresolvable. type NodeToStatusMap map[string]*Status
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0)