- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 189 for newobj (0.31 sec)
-
pkg/scheduler/util/utils.go
// object stored in it will be converted instead. func As[T any](oldObj, newobj interface{}) (T, T, error) { var oldTyped T var newTyped T var ok bool if newobj != nil { newTyped, ok = newobj.(T) if !ok { return oldTyped, newTyped, fmt.Errorf("expected %T, but got %T", newTyped, newobj) } } if oldObj != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 6.2K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/storageversionmigrator.go
} _, _ = svmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { svmController.addSVM(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { svmController.updateSVM(logger, oldObj, newObj) }, }) return svmController } func (svmc *SVMController) Name() string { return svmc.controllerName }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/fit_test.go
if tc.expectedErr { require.Error(t, err) return } require.NoError(t, err) require.Equal(t, tc.expectedHint, actualHint) }) } } func Test_isSchedulableAfterNodeChange(t *testing.T) { testcases := map[string]struct { pod *v1.Pod oldObj, newObj interface{} expectedHint framework.QueueingHint
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/tainttoleration/taint_toleration.go
// pod schedulable. func (pl *TaintToleration) isSchedulableAfterNodeChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { originalNode, modifiedNode, err := util.As[*v1.Node](oldObj, newObj) if err != nil { return framework.Queue, err } wasUntolerated := true if originalNode != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/typeconverter_test.go
if err != nil { t.Fatalf("Failed to convert object to typed: %v", err) } newObj, err := tc.TypedToObject(typed) if err != nil { t.Fatalf("Failed to convert typed to object: %v", err) } if !reflect.DeepEqual(obj, newObj) { t.Errorf(`Round-trip failed: Original object: %#v Final object: %#v`, obj, newObj) } } var result typed.TypedValue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 6.6K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
storageVersionInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { c.onAddStorageVersion(logger, obj) }, UpdateFunc: func(old, newObj interface{}) { c.onUpdateStorageVersion(logger, old, newObj) }, }) return c } // Run starts one worker. func (c *Controller) Run(ctx context.Context) { logger := klog.FromContext(ctx) defer utilruntime.HandleCrash()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates.go
enableSchedulingQueueHint: fts.EnableSchedulingQueueHint, }, nil } func (pl *SchedulingGates) isSchedulableAfterPodChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { _, modifiedPod, err := util.As[*v1.Pod](oldObj, newObj) if err != nil { return framework.Queue, err } if modifiedPod.UID != pod.UID {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/registry/core/resourcequota/strategy.go
// ValidateUpdate is the default update validation for an end user. func (resourcequotaStrategy) ValidateUpdate(ctx context.Context, obj, old runtime.Object) field.ErrorList { newObj, oldObj := obj.(*api.ResourceQuota), old.(*api.ResourceQuota) return validation.ValidateResourceQuotaUpdate(newObj, oldObj) } // WarningsOnUpdate returns warnings for the given update.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 18 17:07:29 UTC 2022 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresourcedefinition/strategy.go
func (statusStrategy) PrepareForUpdate(ctx context.Context, obj, old runtime.Object) { newObj := obj.(*apiextensions.CustomResourceDefinition) oldObj := old.(*apiextensions.CustomResourceDefinition) newObj.Spec = oldObj.Spec // Status updates are for only for updating status, not objectmeta. metav1.ResetObjectMetaForStatus(&newObj.ObjectMeta, &newObj.ObjectMeta) } func (statusStrategy) AllowCreateOnUpdate() bool { return false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 10.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/conversion_test.go
Attributes: attrs( u(`{"apiVersion": "mygroup.k8s.io/v1","kind": "Flunder","metadata":{"name":"newobj"}}`), u(`{"apiVersion": "mygroup.k8s.io/v1","kind": "Flunder","metadata":{"name":"oldobj"}}`), ), VersionedObject: u(`{"apiVersion": "mygroup.k8s.io/v1","kind": "Flunder","metadata":{"name":"newobj"}}`), VersionedOldObject: u(`{"apiVersion": "mygroup.k8s.io/v1","kind": "Flunder","metadata":{"name":"oldobj"}}`),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 13.7K bytes - Viewed (0)