Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for DeleteFunc (0.11 sec)

  1. pkg/kube/krt/informer.go

    			}, 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,
    				Event: controllers.EventDelete,
    			}, false)
    		},
    	}
    }
    
    // WrapClient is the base entrypoint that enables the creation
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 11:01:46 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  2. pkg/kube/namespace/filter.go

    				added := sets.New(new.Name)
    				var removed sets.String
    				if !namespaceAdded {
    					removed = added
    					added = nil
    				}
    				f.notifyHandlersLocked(added, removed)
    			}
    		},
    		DeleteFunc: func(ns *corev1.Namespace) {
    			f.lock.Lock()
    			defer f.lock.Unlock()
    			// No need to notify handlers for deletes. The namespace was deleted, so the object will be as well (and a delete could not de-select).
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 17:12:52 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  3. pilot/pkg/config/kube/crdclient/client.go

    		UpdateFunc: func(old, cur controllers.Object) {
    			incrementEvent(kind, "update")
    			cl.queue.Push(func() error {
    				cl.onEvent(resourceGVK, old, cur, model.EventUpdate)
    				return nil
    			})
    		},
    		DeleteFunc: func(obj controllers.Object) {
    			incrementEvent(kind, "delete")
    			cl.queue.Push(func() error {
    				cl.onEvent(resourceGVK, nil, obj, model.EventDelete)
    				return nil
    			})
    		},
    	})
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 00:12:28 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  4. pkg/controller/job/job_controller.go

    		AddFunc: func(obj interface{}) {
    			jm.addJob(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			jm.updateJob(logger, oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			jm.deleteJob(logger, obj)
    		},
    	}); err != nil {
    		return nil, fmt.Errorf("adding Job event handler: %w", err)
    	}
    	jm.jobLister = jobInformer.Lister()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
Back to top