Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for emitPodDeletionEvent (0.23 sec)

  1. pkg/controller/tainteviction/taint_eviction_test.go

    		case "LastTimestamp", "FirstTimestamp", "ObjectMeta.Name":
    			return true
    		}
    		return false
    	}
    
    	t.Run("emitPodDeletionEvent", func(t *testing.T) {
    		controller := &Controller{}
    		recorder := testutil.NewFakeRecorder()
    		controller.recorder = recorder
    		controller.emitPodDeletionEvent(types.NamespacedName{
    			Name:      "test",
    			Namespace: "test",
    		})
    		want := []*corev1.Event{
    			{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 31.3K bytes
    - Viewed (0)
  2. pkg/controller/tainteviction/taint_eviction.go

    		podUpdateQueue:  workqueue.NewTypedWithConfig(workqueue.TypedQueueConfig[podUpdateItem]{Name: "noexec_taint_pod"}),
    	}
    	tm.taintEvictionQueue = CreateWorkerQueue(deletePodHandler(c, tm.emitPodDeletionEvent, tm.name))
    
    	_, err := podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			pod := obj.(*v1.Pod)
    			tm.PodUpdated(nil, pod)
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 19.9K bytes
    - Viewed (0)
Back to top