Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 119 for NewTestContext (0.19 sec)

  1. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    			}
    			var extenders []framework.Extender
    			if tt.extender != nil {
    				extenders = append(extenders, tt.extender)
    			}
    			logger, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    			f, err := tf.NewFramework(ctx, registeredPlugins, "",
    				frameworkruntime.WithClientSet(cs),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/interpodaffinity/filtering_test.go

    			node: &node1,
    		},
    	}
    
    	for _, test := range tests {
    		t.Run(test.name, func(t *testing.T) {
    			_, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    			snapshot := cache.NewSnapshot(test.pods, []*v1.Node{test.node})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 01 10:24:54 UTC 2023
    - 58.2K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/noderesources/most_allocated_test.go

    				{Name: string(v1.ResourceMemory), Weight: 1},
    			},
    		},
    	}
    
    	for _, test := range tests {
    		t.Run(test.name, func(t *testing.T) {
    			_, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    
    			state := framework.NewCycleState()
    			snapshot := cache.NewSnapshot(test.existingPods, test.nodes)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 16K bytes
    - Viewed (0)
  4. pkg/controller/serviceaccount/tokens_controller_test.go

    			},
    		},
    	}
    
    	for k, tc := range testcases {
    		t.Run(k, func(t *testing.T) {
    			_, ctx := ktesting.NewTestContext(t)
    
    			// Re-seed to reset name generation
    			utilrand.Seed(1)
    
    			generator := &testGenerator{Token: "ABC"}
    
    			client := fake.NewSimpleClientset(tc.ClientObjects...)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 00:05:53 UTC 2023
    - 21.5K bytes
    - Viewed (0)
  5. pkg/controller/deployment/util/deployment_util_test.go

    			expected: false,
    		},
    	}
    
    	for _, test := range tests {
    		t.Run(test.name, func(t *testing.T) {
    			nowFn = test.nowFn
    			_, ctx := ktesting.NewTestContext(t)
    			if got, exp := DeploymentTimedOut(ctx, &test.d, &test.d.Status), test.expected; got != exp {
    				t.Errorf("expected timeout: %t, got: %t", exp, got)
    			}
    		})
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 08 09:10:50 UTC 2023
    - 37.1K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/interpodaffinity/scoring_test.go

    			nodes:      []*v1.Node{},
    			wantStatus: framework.NewStatus(framework.Skip),
    		},
    	}
    	for _, test := range tests {
    		t.Run(test.name, func(t *testing.T) {
    			_, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    			state := framework.NewCycleState()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 44.8K bytes
    - Viewed (0)
  7. pkg/controller/volume/persistentvolume/binder_test.go

    			expectedEvents:  noevents,
    			errors:          noerrors,
    			test:            testSyncClaim,
    		},
    	}
    	_, ctx := ktesting.NewTestContext(t)
    	runSyncTests(t, ctx, tests, []*storage.StorageClass{
    		{
    			ObjectMeta:        metav1.ObjectMeta{Name: classWait},
    			VolumeBindingMode: &modeWait,
    		},
    	}, []*v1.Pod{})
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 65.8K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/noderesources/least_allocated_test.go

    				{Name: string(v1.ResourceMemory), Weight: 1},
    			},
    		},
    	}
    
    	for _, test := range tests {
    		t.Run(test.name, func(t *testing.T) {
    			_, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    
    			state := framework.NewCycleState()
    			snapshot := cache.NewSnapshot(test.existingPods, test.nodes)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 18.8K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/podtopologyspread/filtering_test.go

    			},
    			wantPrefilterStatus: framework.NewStatus(framework.Skip),
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			_, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    			args := &config.PodTopologySpreadArgs{
    				DefaultConstraints: tt.defaultConstraints,
    				DefaultingType:     config.ListDefaulting,
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 143.1K bytes
    - Viewed (0)
  10. cmd/kube-scheduler/app/options/options_test.go

    				if cfg, err := latest.Default(); err != nil {
    					t.Fatal(err)
    				} else {
    					tc.options.ComponentConfig = cfg
    				}
    			}
    			// create the config
    			_, ctx := ktesting.NewTestContext(t)
    			config, err := tc.options.Config(ctx)
    
    			// handle errors
    			if err != nil {
    				if tc.expectedError != "" || tc.checkErrFn != nil {
    					if tc.expectedError != "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 13 07:42:19 UTC 2023
    - 30.3K bytes
    - Viewed (0)
Back to top