Skip to content

Commit a4618d6

Browse files
author
draveness
committed
fix: rename RegisterPriorityFunction2 to RegisterPriorityMapReduceFunction
1 parent b9615d5 commit a4618d6

File tree

3 files changed

+13
-14
lines changed

3 files changed

+13
-14
lines changed

pkg/scheduler/algorithmprovider/defaults/defaults.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -90,9 +90,9 @@ func ApplyFeatureGates() {
9090
// Prioritizes nodes that satisfy pod's resource limits
9191
if utilfeature.DefaultFeatureGate.Enabled(features.ResourceLimitsPriorityFunction) {
9292
klog.Infof("Registering resourcelimits priority function")
93-
factory.RegisterPriorityFunction2(priorities.ResourceLimitsPriority, priorities.ResourceLimitsPriorityMap, nil, 1)
93+
factory.RegisterPriorityMapReduceFunction(priorities.ResourceLimitsPriority, priorities.ResourceLimitsPriorityMap, nil, 1)
9494
// Register the priority function to specific provider too.
95-
factory.InsertPriorityKeyToAlgorithmProviderMap(factory.RegisterPriorityFunction2(priorities.ResourceLimitsPriority, priorities.ResourceLimitsPriorityMap, nil, 1))
95+
factory.InsertPriorityKeyToAlgorithmProviderMap(factory.RegisterPriorityMapReduceFunction(priorities.ResourceLimitsPriority, priorities.ResourceLimitsPriorityMap, nil, 1))
9696
}
9797
}
9898

pkg/scheduler/algorithmprovider/defaults/register_priorities.go

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -46,10 +46,10 @@ func init() {
4646
// EqualPriority is a prioritizer function that gives an equal weight of one to all nodes
4747
// Register the priority function so that its available
4848
// but do not include it as part of the default priorities
49-
factory.RegisterPriorityFunction2(priorities.EqualPriority, core.EqualPriorityMap, nil, 1)
49+
factory.RegisterPriorityMapReduceFunction(priorities.EqualPriority, core.EqualPriorityMap, nil, 1)
5050
// Optional, cluster-autoscaler friendly priority function - give used nodes higher priority.
51-
factory.RegisterPriorityFunction2(priorities.MostRequestedPriority, priorities.MostRequestedPriorityMap, nil, 1)
52-
factory.RegisterPriorityFunction2(
51+
factory.RegisterPriorityMapReduceFunction(priorities.MostRequestedPriority, priorities.MostRequestedPriorityMap, nil, 1)
52+
factory.RegisterPriorityMapReduceFunction(
5353
priorities.RequestedToCapacityRatioPriority,
5454
priorities.RequestedToCapacityRatioResourceAllocationPriorityDefault().PriorityMap,
5555
nil,
@@ -77,21 +77,21 @@ func init() {
7777
)
7878

7979
// Prioritize nodes by least requested utilization.
80-
factory.RegisterPriorityFunction2(priorities.LeastRequestedPriority, priorities.LeastRequestedPriorityMap, nil, 1)
80+
factory.RegisterPriorityMapReduceFunction(priorities.LeastRequestedPriority, priorities.LeastRequestedPriorityMap, nil, 1)
8181

8282
// Prioritizes nodes to help achieve balanced resource usage
83-
factory.RegisterPriorityFunction2(priorities.BalancedResourceAllocation, priorities.BalancedResourceAllocationMap, nil, 1)
83+
factory.RegisterPriorityMapReduceFunction(priorities.BalancedResourceAllocation, priorities.BalancedResourceAllocationMap, nil, 1)
8484

8585
// Set this weight large enough to override all other priority functions.
8686
// TODO: Figure out a better way to do this, maybe at same time as fixing #24720.
87-
factory.RegisterPriorityFunction2(priorities.NodePreferAvoidPodsPriority, priorities.CalculateNodePreferAvoidPodsPriorityMap, nil, 10000)
87+
factory.RegisterPriorityMapReduceFunction(priorities.NodePreferAvoidPodsPriority, priorities.CalculateNodePreferAvoidPodsPriorityMap, nil, 10000)
8888

8989
// Prioritizes nodes that have labels matching NodeAffinity
90-
factory.RegisterPriorityFunction2(priorities.NodeAffinityPriority, priorities.CalculateNodeAffinityPriorityMap, priorities.CalculateNodeAffinityPriorityReduce, 1)
90+
factory.RegisterPriorityMapReduceFunction(priorities.NodeAffinityPriority, priorities.CalculateNodeAffinityPriorityMap, priorities.CalculateNodeAffinityPriorityReduce, 1)
9191

9292
// Prioritizes nodes that marked with taint which pod can tolerate.
93-
factory.RegisterPriorityFunction2(priorities.TaintTolerationPriority, priorities.ComputeTaintTolerationPriorityMap, priorities.ComputeTaintTolerationPriorityReduce, 1)
93+
factory.RegisterPriorityMapReduceFunction(priorities.TaintTolerationPriority, priorities.ComputeTaintTolerationPriorityMap, priorities.ComputeTaintTolerationPriorityReduce, 1)
9494

9595
// ImageLocalityPriority prioritizes nodes that have images requested by the pod present.
96-
factory.RegisterPriorityFunction2(priorities.ImageLocalityPriority, priorities.ImageLocalityPriorityMap, nil, 1)
96+
factory.RegisterPriorityMapReduceFunction(priorities.ImageLocalityPriority, priorities.ImageLocalityPriorityMap, nil, 1)
9797
}

pkg/scheduler/factory/plugins.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -278,10 +278,9 @@ func RegisterPriorityFunction(name string, function priorities.PriorityFunction,
278278
})
279279
}
280280

281-
// RegisterPriorityFunction2 registers a priority function with the algorithm registry. Returns the name,
281+
// RegisterPriorityMapReduceFunction registers a priority function with the algorithm registry. Returns the name,
282282
// with which the function was registered.
283-
// FIXME: Rename to PriorityFunctionFactory.
284-
func RegisterPriorityFunction2(
283+
func RegisterPriorityMapReduceFunction(
285284
name string,
286285
mapFunction priorities.PriorityMapFunction,
287286
reduceFunction priorities.PriorityReduceFunction,

0 commit comments

Comments
 (0)