- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,455 for fairness (0.16 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_context.go
// to priority and fairness dispatcher. func initializationSignalFrom(ctx context.Context) (InitializationSignal, bool) { signal, ok := ctx.Value(priorityAndFairnessInitializationSignalKey).(InitializationSignal) return signal, ok && signal != nil } // WatchInitialized sends a signal to priority and fairness dispatcher // that a given watch request has already been initialized.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 14 14:39:15 UTC 2021 - 2.9K bytes - Viewed (0) -
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) -
staging/src/k8s.io/apiserver/pkg/endpoints/request/webhook_duration_test.go
t.Errorf("expected validate duration: %q, but got: %q", tc.MaxDuration, wd.ValidatingWebhookTracker.GetLatency()) } if wd.APFQueueWaitTracker.GetLatency() != tc.MaxDuration { t.Errorf("expected priority & fairness duration: %q, but got: %q", tc.MaxDuration, wd.APFQueueWaitTracker.GetLatency()) } })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 09:15:20 UTC 2023 - 2.4K 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) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/interface.go
NewForLabelValuesSafe(initialNumerator, initialDenominator float64, labelValues []string) RatioedGauge } //////////////////////////////// Pairs //////////////////////////////// // // API Priority and Fairness tends to use RatioedGaugeVec members in pairs, // one for requests waiting in a queue and one for requests being executed. // The following definitions are a convenience layer that adds support for that
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 13 03:37:15 UTC 2022 - 2.5K 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)