- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 51 for casgstatus (0.11 sec)
-
pkg/scheduler/framework/plugins/podtopologyspread/scoring.go
nodeInfo, err := pl.sharedLister.NodeInfos().Get(nodeName) if err != nil { return 0, framework.AsStatus(fmt.Errorf("getting node %q from Snapshot: %w", nodeName, err)) } node := nodeInfo.Node() s, err := getPreScoreState(cycleState) if err != nil { return 0, framework.AsStatus(err) } // Return if the node is not qualified. if s.IgnoredNodes.Has(node.Name) { return 0, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 10.1K bytes - Viewed (0) -
common-protos/k8s.io/apimachinery/pkg/apis/testapigroup/v1/generated.proto
// If not specified, the carp will be dispatched by default scheduler. // +optional optional string schedulername = 19; } // CarpStatus represents information about the status of a carp. Status may trail the actual // state of a system. message CarpStatus { // Current condition of the carp. // More info: http://kubernetes.io/docs/user-guide/carp-states#carp-phase // +optional optional string phase = 1;
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 7.7K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
// So we need to execute all PreFilter. // https://github.com/kubernetes/kubernetes/issues/119770 returnStatus = s continue } return nil, framework.AsStatus(fmt.Errorf("running PreFilter plugin %q: %w", pl.Name(), s.AsError())).WithPlugin(pl.Name()) } if !r.AllNodes() { pluginsWithNodes = append(pluginsWithNodes, pl.Name()) } result = result.Merge(r)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/filtering.go
s, err := pl.calPreFilterState(ctx, pod) if err != nil { return nil, framework.AsStatus(err) } else if s != nil && len(s.Constraints) == 0 { return nil, framework.NewStatus(framework.Skip) } cycleState.Write(preFilterStateKey, s) return nil, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 10:42:29 UTC 2024 - 12.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/imagelocality/image_locality.go
nodeInfo, err := pl.handle.SnapshotSharedLister().NodeInfos().Get(nodeName) if err != nil { return 0, framework.AsStatus(fmt.Errorf("getting node %q from Snapshot: %w", nodeName, err)) } nodeInfos, err := pl.handle.SnapshotSharedLister().NodeInfos().List() if err != nil { return 0, framework.AsStatus(err) } totalNumNodes := len(nodeInfos) imageScores := sumImageScores(nodeInfo, pod, totalNumNodes)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 19 06:17:57 UTC 2024 - 5K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/validator.go
return errs } var allErrs field.ErrorList allErrs = append(allErrs, validation.ValidateObjectMetaAccessorUpdate(obj, old, field.NewPath("metadata"))...) if status, hasStatus := obj.UnstructuredContent()["status"]; hasStatus { allErrs = append(allErrs, apiextensionsvalidation.ValidateCustomResourceUpdate(field.NewPath("status"), status, old.UnstructuredContent()["status"], a.statusSchemaValidator)...) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 14:00:05 UTC 2024 - 7.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultbinder/default_binder.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 2K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework_test.go
}, { name: "ErrorFilter", plugins: []*TestPlugin{ { name: "TestPlugin", inj: injectedResult{FilterStatus: int(framework.Error)}, }, }, wantStatus: framework.AsStatus(fmt.Errorf(`running "TestPlugin" filter plugin: %w`, errInjectedFilterStatus)).WithPlugin("TestPlugin"), }, { name: "UnschedulableFilter", plugins: []*TestPlugin{ { name: "TestPlugin",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 103K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
pod, err := ev.PodLister.Pods(pod.Namespace).Get(pod.Name) if err != nil { logger.Error(err, "Could not get the updated preemptor pod object", "pod", klog.KRef(podNamespace, podName)) return nil, framework.AsStatus(err) } // 1) Ensure the preemptor is eligible to preempt other pods. if ok, msg := ev.PodEligibleToPreemptOthers(pod, m[pod.Status.NominatedNodeName]); !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeaffinity/node_affinity.go
if len(nodes) == 0 { return nil } preferredNodeAffinity, err := getPodPreferredNodeAffinity(pod) if err != nil { return framework.AsStatus(err) } if preferredNodeAffinity == nil && pl.addedPrefSchedTerms == nil { // NodeAffinity Score has nothing to do with the Pod. return framework.NewStatus(framework.Skip) } state := &preScoreState{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Dec 18 12:00:10 UTC 2023 - 12.6K bytes - Viewed (0)