- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 45 for oldObj (0.5 sec)
-
pkg/controller/storageversionmigrator/resourceversion.go
), } _, _ = svmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { rvController.addSVM(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { rvController.updateSVM(logger, oldObj, newObj) }, }) return rvController } func (rv *ResourceVersionController) addSVM(logger klog.Logger, obj interface{}) { svm := obj.(*svmv1alpha1.StorageVersionMigration)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/registry/rbac/role/policybased/storage.go
} nonEscalatingInfo := rest.WrapUpdatedObjectInfo(obj, func(ctx context.Context, obj runtime.Object, oldObj runtime.Object) (runtime.Object, error) { role := obj.(*rbac.Role) // if we're only mutating fields needed for the GC to eventually delete this obj, return if rbacregistry.IsOnlyMutatingGCFields(obj, oldObj, kapihelper.Semantic) { return obj, nil } rules := role.Rules
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 10:11:16 UTC 2022 - 3.9K 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/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) -
pkg/registry/rbac/clusterrole/strategy.go
func (strategy) ValidateUpdate(ctx context.Context, obj, old runtime.Object) field.ErrorList { newObj := obj.(*rbac.ClusterRole) oldObj := old.(*rbac.ClusterRole) opts := validation.ClusterRoleValidationOptions{ AllowInvalidLabelValueInSelector: hasInvalidLabelValueInLabelSelector(oldObj), } errorList := validation.ValidateClusterRole(newObj, opts)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 01:52:02 UTC 2022 - 4.2K 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
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. func (resourcequotaStrategy) WarningsOnUpdate(ctx context.Context, obj, old runtime.Object) []string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 18 17:07:29 UTC 2022 - 4.7K bytes - Viewed (0) -
pkg/registry/rbac/clusterrolebinding/policybased/storage.go
} nonEscalatingInfo := rest.WrapUpdatedObjectInfo(obj, func(ctx context.Context, obj runtime.Object, oldObj runtime.Object) (runtime.Object, error) { clusterRoleBinding := obj.(*rbac.ClusterRoleBinding) // if we're only mutating fields needed for the GC to eventually delete this obj, return if rbacregistry.IsOnlyMutatingGCFields(obj, oldObj, kapihelper.Semantic) { return obj, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 10:11:16 UTC 2022 - 4.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeunschedulable/node_unschedulable.go
// pod schedulable. func (pl *NodeUnschedulable) isSchedulableAfterNodeChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { _, modifiedNode, err := util.As[*v1.Node](oldObj, newObj) if err != nil { return framework.Queue, err } if !modifiedNode.Spec.Unschedulable {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 16 12:50:11 UTC 2023 - 3.9K bytes - Viewed (0) -
pkg/registry/rbac/rolebinding/policybased/storage.go
return s.StandardStorage.Update(ctx, name, obj, createValidation, updateValidation, forceAllowCreate, options) } nonEscalatingInfo := rest.WrapUpdatedObjectInfo(obj, func(ctx context.Context, obj runtime.Object, oldObj runtime.Object) (runtime.Object, error) { // Get the namespace from the context (populated from the URL). // The namespace in the object can be empty until StandardStorage.Update()->BeforeUpdate() populates it from the context.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 10:11:16 UTC 2022 - 5.5K bytes - Viewed (0)