- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for newobj (0.13 sec)
-
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) -
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) -
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) -
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) -
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) -
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)