Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for TestUpdatePod (0.14 sec)

  1. 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)
  2. 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)
  3. 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