Skip to content

Commit

Permalink
test: Update scheduling benchmarker to use v1beta1 APIs (kubernetes…
Browse files Browse the repository at this point in the history
  • Loading branch information
jonathan-innis authored Sep 19, 2023
1 parent f56b977 commit d381e1b
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -117,14 +117,14 @@ func benchmarkScheduler(b *testing.B, instanceCount, podCount int) {
// disable logging
ctx = logging.WithLogger(context.Background(), zap.NewNop().Sugar())
ctx = settings.ToContext(ctx, test.Settings())
provisioner := test.Provisioner(test.ProvisionerOptions{Limits: map[v1.ResourceName]resource.Quantity{}})
nodePool := test.NodePool()

instanceTypes := fake.InstanceTypes(instanceCount)
cloudProvider = fake.NewCloudProvider()
cloudProvider.InstanceTypes = instanceTypes
scheduler := scheduling.NewScheduler(ctx, nil, []*scheduling.NodeClaimTemplate{scheduling.NewNodeClaimTemplate(nodepool.New(provisioner))},
scheduler := scheduling.NewScheduler(ctx, nil, []*scheduling.NodeClaimTemplate{scheduling.NewNodeClaimTemplate(nodePool)},
nil, state.NewCluster(&clock.RealClock{}, nil, cloudProvider), nil, &scheduling.Topology{},
map[nodepool.Key][]*cloudprovider.InstanceType{nodepool.Key{Name: provisioner.Name, IsProvisioner: true}: instanceTypes}, nil,
map[nodepool.Key][]*cloudprovider.InstanceType{nodepool.Key{Name: nodePool.Name, IsProvisioner: false}: instanceTypes}, nil,
events.NewRecorder(&record.FakeRecorder{}),
scheduling.SchedulerOptions{})

Expand Down

0 comments on commit d381e1b

Please sign in to comment.