- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 55 for Prioritize (0.14 sec)
-
pkg/scheduler/testing/framework/fake_extender.go
} // Prioritize implements the extender Prioritize function. func (f *FakeExtender) Prioritize(pod *v1.Pod, nodes []*framework.NodeInfo) (*extenderv1.HostPriorityList, int64, error) { result := extenderv1.HostPriorityList{} combinedScores := map[string]int64{} for _, prioritizer := range f.Prioritizers { weight := prioritizer.Weight if weight == 0 { continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.9K bytes - Viewed (0) -
pkg/scheduler/framework/extender.go
// Prioritize based on extender-implemented priority functions. The returned scores & weight // are used to compute the weighted score for an extender. The weighted scores are added to // the scores computed by Kubernetes scheduler. The total scores are used to do the host selection.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/util/filesystem/watcher.go
// in case the file changed concurrent with calling WatchUntil. eventHandler() } for { select { case <-ctx.Done(): return case <-t.C: // Prioritize exiting if context is canceled if ctx.Err() != nil { return } // Try to re-establish the watcher if we previously got a watch error if attemptPeriodicRewatch { _ = watcher.Remove(path)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 14 23:09:15 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/scheduler/apis/config/types.go
PreemptVerb string // Verb for the prioritize call, empty if not supported. This verb is appended to the URLPrefix when issuing the prioritize call to extender. PrioritizeVerb string // The numeric multiplier for the node scores that the prioritize call generates. // The weight should be a positive integer Weight int64
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 18:47:23 UTC 2024 - 14.8K bytes - Viewed (0) -
maven-di/src/main/java/org/apache/maven/di/impl/Binding.java
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Mar 25 10:50:01 UTC 2024 - 5.9K bytes - Viewed (0) -
pkg/scheduler/extender.go
} // Prioritize based on extender implemented priority functions. Weight*priority is added // up for each such priority function. The returned score is added to the score computed // by Kubernetes scheduler. The total score is used to do the host selection. func (h *HTTPExtender) Prioritize(pod *v1.Pod, nodes []*framework.NodeInfo) (*extenderv1.HostPriorityList, int64, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/transforms/xla_legalize_tf_passes.td
"The device type used by TF2XLA fallback. Must be specified if " "use-tf2xla-fallback is true, otherwise not used">, Option<"prefer_tf2xla_", "prefer-tf2xla", "bool", /*default=*/"false", "Prioritize tf2xla fallback legalization over MLIR legalization " "patterns">, ]; let constructor = "mlir::mhlo::createLegalizeTFPass()"; let dependentDialects = [ "arith::ArithDialect",
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Mar 21 17:44:14 UTC 2024 - 4.3K bytes - Viewed (0) -
pkg/scheduler/apis/config/validation/validation_test.go
Enabled: []config.Plugin{{Name: "CustomSort"}}, }, Bind: config.PluginSet{ Enabled: []config.Plugin{{Name: "CustomBind"}}, }, }, }}, Extenders: []config.Extender{{ PrioritizeVerb: "prioritize", Weight: 1, }}, } invalidParallelismValue := validConfig.DeepCopy() invalidParallelismValue.Parallelism = 0 resourceNameNotSet := validConfig.DeepCopy()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 06:27:01 UTC 2024 - 12.2K bytes - Viewed (0) -
maven-di/src/main/java/org/apache/maven/di/impl/ReflectionUtils.java
}, toDependencies(method.getDeclaringClass(), method)); Priority priority = method.getAnnotation(Priority.class); if (priority != null) { binding = binding.prioritize(priority.value()); } return binding; } public static <T> Binding<T> bindingFromConstructor(Key<T> key, Constructor<T> constructor) { constructor.setAccessible(true);
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Feb 09 17:13:31 UTC 2024 - 16K bytes - Viewed (0) -
pilot/pkg/credentials/kube/multicluster.go
agg.controllers = []*CredentialsController{} agg.authController = *cc if clusterID != m.configCluster { // If the request cluster is not the config cluster, we will append it and use it for auth // This means we will prioritize the proxy cluster, then the config cluster for credential lookup // Authorization will always use the proxy cluster. agg.controllers = append(agg.controllers, *cc) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 4.2K bytes - Viewed (0)