- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 45 for oldObj (0.22 sec)
-
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/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) -
pkg/kube/kclient/clienttest/test_helpers.go
return controllers.EventHandler[controllers.Object]{ AddFunc: func(obj controllers.Object) { tracker.Record("add/" + obj.GetName()) }, UpdateFunc: func(oldObj, newObj controllers.Object) { tracker.Record("update/" + newObj.GetName()) }, DeleteFunc: func(obj controllers.Object) { tracker.Record("delete/" + obj.GetName()) }, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/controller/validatingadmissionpolicystatus/controller.go
typeChecker: typeChecker, } reg, err := policyInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { c.enqueuePolicy(obj) }, UpdateFunc: func(oldObj, newObj interface{}) { c.enqueuePolicy(newObj) }, }) if err != nil { return nil, err } c.policySynced = reg.HasSynced return c, nil } func (c *Controller) enqueuePolicy(policy any) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 5.3K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller.go
creationRatelimiter: limiter, clock: cl, } informer.AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { c.enqueue() }, UpdateFunc: func(oldObj, newObj interface{}) { c.enqueue() }, DeleteFunc: func(obj interface{}) { c.enqueue() }, }) return c } func (c *Controller) enqueue() { c.queue.Add(queueKey) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K 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) -
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) -
pkg/controller/serviceaccount/serviceaccounts_controller.go
c.queue.Add(namespace.Name) } // namespaceUpdated reacts to a Namespace update (or re-list) by creating a default ServiceAccount in the namespace if needed func (c *ServiceAccountsController) namespaceUpdated(oldObj interface{}, newObj interface{}) { newNamespace := newObj.(*v1.Namespace) c.queue.Add(newNamespace.Name) } func (c *ServiceAccountsController) runWorker(ctx context.Context) { for c.processNextWorkItem(ctx) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0)