- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 436 for fairness (0.16 sec)
-
staging/src/k8s.io/apiserver/pkg/server/options/feature.go
"Use an unprotected (no authn/authz) unix-domain socket for profiling with the given path") fs.BoolVar(&o.EnablePriorityAndFairness, "enable-priority-and-fairness", o.EnablePriorityAndFairness, ""+ "If true, replace the max-in-flight handler with an enhanced one that queues and dispatches with priority and fairness") } func (o *FeatureOptions) ApplyTo(c *server.Config, clientset kubernetes.Interface, informers informers.SharedInformerFactory) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 18:51:27 UTC 2024 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter.go
) // ConfigConsumerAsFieldManager is how the config consuminng // controller appears in an ObjectMeta ManagedFieldsEntry.Manager const ConfigConsumerAsFieldManager = "api-priority-and-fairness-config-consumer-v1" // Interface defines how the API Priority and Fairness filter interacts with the underlying system. type Interface interface { // Handle takes care of queuing and dispatching a request
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 8K bytes - Viewed (0) -
pkg/apis/flowcontrol/internalbootstrap/default-internal.go
// NewAPFScheme constructs and returns a Scheme configured to handle // the API object types that are used to configure API Priority and // Fairness func NewAPFScheme() *runtime.Scheme { scheme := runtime.NewScheme() install.Install(scheme) return scheme } func internalizeFSes(exts []*flowcontrolv1.FlowSchema) map[string]*flowcontrol.FlowSchema {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 2.5K bytes - Viewed (0) -
testing/internal-performance-testing/src/main/groovy/org/gradle/performance/fixture/PerformanceTestGradleDistribution.groovy
import org.gradle.test.fixtures.file.TestFile import org.gradle.util.internal.GFileUtils /** * Gradle's performance slightly depends on the length of the Gradle home path. This * class ensures fairness between the version under development and the baseline versions, * which live at different depth inside the Gradle repository. */ @CompileStatic class PerformanceTestGradleDistribution implements GradleDistribution {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.2K bytes - Viewed (0) -
pkg/controlplane/apiserver/options/validation.go
for _, testConfig := range testConfigs { if strings.Contains(enabledAPIString, fmt.Sprintf("%s=false", testConfig)) { return []error{fmt.Errorf("--runtime-config=%s=false conflicts with --enable-priority-and-fairness=true", testConfig)} } if strings.Contains(enabledAPIString, fmt.Sprintf("%s=true", testConfig)) { return nil } } } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 12:46:24 UTC 2023 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/width.go
} return estimator.estimate } // WorkEstimatorFunc returns the estimated work of a given request. // This function will be used by the Priority & Fairness filter to // estimate the work of of incoming requests. type WorkEstimatorFunc func(request *http.Request, flowSchemaName, priorityLevelName string) WorkEstimate
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:26:52 UTC 2023 - 5K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/server.go
"--authorization-kubeconfig", fakeKubeConfig.Name(), "--kubeconfig", fakeKubeConfig.Name(), // disable admission and filters that require talking to kube-apiserver "--enable-priority-and-fairness=false", "--disable-admission-plugins", "NamespaceLifecycle,MutatingAdmissionWebhook,ValidatingAdmissionWebhook,ValidatingAdmissionPolicy"}, flags..., ), nil) if err != nil { os.Remove(fakeKubeConfig.Name())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/controlplane/apiserver/options/validation_test.go
kubeoptions "k8s.io/kubernetes/pkg/kubeapiserver/options" ) func TestValidateAPIPriorityAndFairness(t *testing.T) { const conflict = "conflicts with --enable-priority-and-fairness=true" tests := []struct { runtimeConfig string errShouldContain string }{ { runtimeConfig: "api/all=false", errShouldContain: conflict, }, { runtimeConfig: "api/beta=false",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 8.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/format/formatting.go
) // This file provides an easy way to mark a value for formatting to // `%s` in full detail IF it is printed but without costing a lot of // CPU or memory if the value is NOT printed. The API Priority and // Fairness API objects are formatted into JSON. The other types of // objects here are formatted into golang source. // Stringer marks the given value for custom formatting by this package. type Stringer struct{ val interface{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 7.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/interface.go
// functionality described in the "Assignment to a Queue", "Queuing", // and "Dispatching" sections of // https://github.com/kubernetes/enhancements/blob/master/keps/sig-api-machinery/1040-priority-and-fairness/README.md // . Some day we may have connections between priority levels, but // today is not that day. type QueueSet interface { // BeginConfigChange starts the two-step process of updating the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 6.4K bytes - Viewed (0)