- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 75 for oldObj (0.1 sec)
-
pkg/scheduler/framework/plugins/noderesources/fit_test.go
testcases := map[string]struct { pod *v1.Pod oldObj, newObj interface{} enableInPlacePodVerticalScaling bool expectedHint framework.QueueingHint expectedErr bool }{ "backoff-wrong-old-object": { pod: &v1.Pod{}, oldObj: "not-a-pod", enableInPlacePodVerticalScaling: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 57.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/interpodaffinity/plugin.go
return } func (pl *InterPodAffinity) isSchedulableAfterPodChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { originalPod, modifiedPod, err := util.As[*v1.Pod](oldObj, newObj) if err != nil { return framework.Queue, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 03:08:44 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
PluginName string QueueingHintFn framework.QueueingHintFn } // clusterEvent has the event and involved objects. type clusterEvent struct { event framework.ClusterEvent // oldObj is the object that involved this event. oldObj interface{} // newObj is the object that involved this event. newObj interface{} } type priorityQueueOptions struct { clock clock.Clock
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/validation/validation.go
requireOpenAPISchema: requireOpenAPISchema(&oldObj.Spec), requireValidPropertyType: requireValidPropertyType(&oldObj.Spec), requireStructuralSchema: requireStructuralSchema(&oldObj.Spec), requirePrunedDefaults: requirePrunedDefaults(&oldObj.Spec), requireAtomicSetType: requireAtomicSetType(&oldObj.Spec),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 82.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/plugin.go
} func (pl *PodTopologySpread) isSchedulableAfterPodChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { originalPod, modifiedPod, err := util.As[*v1.Pod](oldObj, newObj) if err != nil { return framework.Queue, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeports/node_ports.go
// that change made a previously unschedulable pod schedulable. func (pl *NodePorts) isSchedulableAfterPodDeleted(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { deletedPod, _, err := util.As[*v1.Pod](oldObj, nil) if err != nil { return framework.Queue, err } // If the deleted pod is unscheduled, it doesn't make the target pod schedulable.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 10:53:29 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/kube/krt/informer.go
AddExtendedFunc: func(obj I, initialSync bool) { handler(Event[I]{ New: &obj, Event: controllers.EventAdd, }, initialSync) }, UpdateFunc: func(oldObj, newObj I) { handler(Event[I]{ Old: &oldObj, New: &newObj, Event: controllers.EventUpdate, }, false) }, DeleteFunc: func(obj I) { handler(Event[I]{ Old: &obj,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 11:01:46 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/fit.go
// that change made a previously unschedulable pod schedulable. func (f *Fit) isSchedulableAfterPodChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { originalPod, modifiedPod, err := schedutil.As[*v1.Pod](oldObj, newObj) if err != nil { return framework.Queue, err } if modifiedPod == nil { if originalPod.Spec.NodeName == "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 20.2K bytes - Viewed (0) -
pkg/controlplane/controller/crdregistration/crdregistration_controller.go
cast := obj.(*apiextensionsv1.CustomResourceDefinition) c.enqueueCRD(cast) }, UpdateFunc: func(oldObj, newObj interface{}) { // Enqueue both old and new object to make sure we remove and add appropriate API services. // The working queue will resolve any duplicates and only changes will stay in the queue. c.enqueueCRD(oldObj.(*apiextensionsv1.CustomResourceDefinition)) c.enqueueCRD(newObj.(*apiextensionsv1.CustomResourceDefinition))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
} c.queue.Add(key) } registration, err := c.informer.AddEventHandler(cache.ResourceEventHandlerDetailedFuncs{ AddFunc: enqueue, UpdateFunc: func(oldObj, newObj interface{}) { oldMeta, err1 := meta.Accessor(oldObj) newMeta, err2 := meta.Accessor(newObj) if err1 != nil || err2 != nil { if err1 != nil { utilruntime.HandleError(err1) } if err2 != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0)