Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for TestUpdatePod (0.2 sec)

  1. pkg/controller/tainteviction/taint_eviction_test.go

    	}
    	controller.PodUpdated(testutil.NewPod("pod1", "node1"), nil)
    	// wait a bit to see if nothing will panic
    	time.Sleep(timeForControllerToProgressForSanityCheck)
    }
    
    func TestUpdatePod(t *testing.T) {
    	testCases := []struct {
    		description                   string
    		prevPod                       *corev1.Pod
    		awaitForScheduledEviction     bool
    		newPod                        *corev1.Pod
    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/kubelet/pod_workers_test.go

    		last := len(events) - 1
    		if events[last].name != strconv.Itoa(i) {
    			t.Errorf("Pod %v: incorrect order %v, %#v", i, last, events)
    		}
    	}
    }
    
    func TestUpdatePod(t *testing.T) {
    	one := int64(1)
    	hasContext := func(status *podSyncStatus) *podSyncStatus {
    		status.ctx, status.cancelFn = context.Background(), func() {}
    		return status
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  3. pkg/scheduler/schedule_one_test.go

    				if gotBound := ext.(*fakeExtender).gotBind; gotBound != wantBound {
    					t.Errorf("got bound with extender #%d: %v, want %v", i, gotBound, wantBound)
    				}
    			}
    
    		})
    	}
    }
    
    func TestUpdatePod(t *testing.T) {
    	tests := []struct {
    		name                     string
    		currentPodConditions     []v1.PodCondition
    		newPodCondition          *v1.PodCondition
    		currentNominatedNodeName string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  4. pkg/controller/daemon/daemon_controller_test.go

    		}
    		if got, want := getQueuedKeys(manager.queue), []string{"default/foo1", "default/foo2"}; !reflect.DeepEqual(got, want) {
    			t.Errorf("getQueuedKeys() = %v, want %v", got, want)
    		}
    	}
    }
    
    func TestUpdatePod(t *testing.T) {
    	for _, strategy := range updateStrategies() {
    		logger, ctx := ktesting.NewTestContext(t)
    		manager, _, _, err := newTestController(ctx)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.4K bytes
    - Viewed (0)
  5. pkg/controller/job/job_controller_test.go

    	pod1.OwnerReferences = nil
    	informer.Core().V1().Pods().Informer().GetIndexer().Add(pod1)
    
    	jm.addPod(logger, pod1)
    	verifyEmptyQueueAndAwaitForQueueLen(ctx, t, jm, 2)
    }
    
    func TestUpdatePod(t *testing.T) {
    	t.Cleanup(setDurationDuringTest(&syncJobBatchPeriod, fastSyncJobBatchPeriod))
    	_, ctx := ktesting.NewTestContext(t)
    	logger := klog.FromContext(ctx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
Back to top