- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 120 for oldObj (0.15 sec)
-
pkg/scheduler/internal/queue/scheduling_queue_test.go
count++ return framework.Queue, nil } queueHintReturnSkip := func(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { count++ return framework.QueueSkip, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
plugin/pkg/admission/limitranger/admission.go
if !l.actions.SupportsAttributes(a) { return nil } // ignore all objects marked for deletion oldObj := a.GetOldObject() if oldObj != nil { oldAccessor, err := meta.Accessor(oldObj) if err != nil { return admission.NewForbidden(a, err) } if oldAccessor.GetDeletionTimestamp() != nil { return nil } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 13:04:39 UTC 2023 - 25.8K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/publisher.go
} c.queue.Add(cm.Namespace) } func (c *Publisher) namespaceAdded(obj interface{}) { namespace := obj.(*v1.Namespace) c.queue.Add(namespace.Name) } func (c *Publisher) namespaceUpdated(oldObj interface{}, newObj interface{}) { newNamespace := newObj.(*v1.Namespace) if newNamespace.Status.Phase != v1.NamespaceActive { return } c.queue.Add(newNamespace.Name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/scheduler/framework/types.go
// - `oldObj` `newObj`: the object involved in that event. // - For example, the given event is "Node deleted", the `oldObj` will be that deleted Node. // - `oldObj` is nil if the event is add event. // - `newObj` is nil if the event is delete event. type QueueingHintFn func(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (QueueingHint, error) type QueueingHint int
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 19:28:17 UTC 2024 - 36.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
func (pl *dynamicResources) isSchedulableAfterClaimParametersChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { originalParameters, modifiedParameters, err := schedutil.As[*resourcev1alpha2.ResourceClaimParameters](oldObj, newObj) if err != nil { // Shouldn't happen.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
pilot/pkg/status/distribution/state.go
} type DistroReportHandler struct { dc *Controller } func (drh *DistroReportHandler) OnAdd(obj any, _ bool) { drh.HandleNew(obj) } func (drh *DistroReportHandler) OnUpdate(oldObj, newObj any) { drh.HandleNew(newObj) } func (drh *DistroReportHandler) HandleNew(obj any) { cm, ok := obj.(*v1.ConfigMap) if !ok { scope.Warnf("expected configmap, but received %v, discarding", obj)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.7K bytes - Viewed (0) -
plugin/pkg/admission/noderestriction/admission_test.go
subresource string newObj runtime.Object oldObj runtime.Object expansionFeatureEnabled bool recoveryFeatureEnabled bool expectError string }{ { name: "should not allow full pvc update from nodes", oldObj: makeTestPVC( api.PersistentVolumeClaimResizing, "10G", nil, ), subresource: "",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 73.2K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { dc.addPod(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { dc.updatePod(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { dc.deletePod(logger, obj) }, }) dc.podLister = podInformer.Lister() dc.podListerSynced = podInformer.Informer().HasSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
), } rsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { rsc.addRS(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { rsc.updateRS(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { rsc.deleteRS(logger, obj) }, }) rsInformer.Informer().AddIndexers(cache.Indexers{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/registry/apps/deployment/storage/storage.go
func (i *scaleUpdatedObjectInfo) Preconditions() *metav1.Preconditions { return i.reqObjInfo.Preconditions() } func (i *scaleUpdatedObjectInfo) UpdatedObject(ctx context.Context, oldObj runtime.Object) (runtime.Object, error) { deployment, ok := oldObj.DeepCopyObject().(*apps.Deployment) if !ok { return nil, errors.NewBadRequest(fmt.Sprintf("expected existing object type to be Deployment, got %T", deployment)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 16.8K bytes - Viewed (0)