Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for newobj (0.13 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/cel/validation_test.go

    				budget = celconfig.RuntimeCELCostBudget
    			}
    			errs, _ := validator.Validate(
    				ctx,
    				field.NewPath("root"),
    				c.schema,
    				c.newObj,
    				c.oldObj,
    				budget,
    				WithRatcheting(common.NewCorrelatedObject(c.newObj, c.oldObj, &model.Structural{Structural: c.schema})),
    			)
    
    			require.Len(t, errs, len(c.errors), "must have expected number of errors")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 17:14:10 UTC 2024
    - 159.9K bytes
    - Viewed (0)
  2. pkg/scheduler/internal/queue/scheduling_queue_test.go

    		count++
    		return framework.Queue, nil
    	}
    	queueHintReturnSkip := func(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    		count++
    		return framework.QueueSkip, nil
    	}
    	queueHintReturnErr := func(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    			t.Fatalf("unexpected error: %v", err)
    		}
    
    		transformer := func(ctx context.Context, newObj runtime.Object, oldObj runtime.Object) (transformedNewObj runtime.Object, err error) {
    			<-ready
    			pod, ok := newObj.(*example.Pod)
    			if !ok {
    				t.Fatalf("unexpected object %v", newObj)
    			}
    			pod.Labels = map[string]string{
    				"modified": "true",
    			}
    			return pod, nil
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  4. pkg/registry/batch/job/strategy_test.go

    			featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.JobBackoffLimitPerIndex, tc.enableJobBackoffLimitPerIndex)
    			newJob := tc.job.DeepCopy()
    			tc.update(newJob)
    			errs := Strategy.ValidateUpdate(ctx, newJob, tc.job)
    			if diff := cmp.Diff(tc.wantErrs, errs, ignoreErrValueDetail); diff != "" {
    				t.Errorf("Unexpected errors (-want,+got):\n%s", diff)
    			}
    		})
    	}
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 101.5K bytes
    - Viewed (0)
  5. pkg/controller/job/job_controller_test.go

    			manager.jobStoreSynced = alwaysReady
    
    			sharedInformerFactory.Batch().V1().Jobs().Informer().GetIndexer().Add(tc.oldJob)
    			newJob := tc.oldJob.DeepCopy()
    			if tc.updateFn != nil {
    				tc.updateFn(newJob)
    			}
    			manager.updateJob(logger, tc.oldJob, newJob)
    			gotRequeuedImmediately := manager.queue.Len() > 0
    			if tc.wantRequeuedImmediately != gotRequeuedImmediately {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  6. src/reflect/all_test.go

    		var info []caseInfo
    
    		// Ready send.
    		if x.Maybe() {
    			ch, val := newop(len(cases), 1)
    			cases = append(cases, SelectCase{
    				Dir:  SelectSend,
    				Chan: ch,
    				Send: val,
    			})
    			info = append(info, caseInfo{desc: "ready send", canSelect: true})
    		}
    
    		// Ready recv.
    		if x.Maybe() {
    			ch, val := newop(len(cases), 1)
    			ch.Send(val)
    			cases = append(cases, SelectCase{
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 218.8K bytes
    - Viewed (0)
Back to top