- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,004 for fairness (0.13 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go
"k8s.io/klog/v2" utilsclock "k8s.io/utils/clock" ) // PriorityAndFairnessClassification identifies the results of // classification for API Priority and Fairness type PriorityAndFairnessClassification struct { FlowSchemaName string FlowSchemaUID apitypes.UID PriorityLevelName string PriorityLevelUID apitypes.UID }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 15.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/metrics.go
&compbasemetrics.CounterOpts{ Namespace: namespace, Subsystem: subsystem, Name: "rejected_requests_total", Help: "Number of requests rejected by API Priority and Fairness subsystem", StabilityLevel: compbasemetrics.BETA, }, []string{priorityLevel, flowSchema, "reason"}, ) apiserverDispatchedRequestsTotal = compbasemetrics.NewCounterVec( &compbasemetrics.CounterOpts{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 24 19:40:05 UTC 2023 - 25.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
klog.Info("Starting API Priority and Fairness config controller") if ok := cache.WaitForCacheSync(stopCh, cfgCtlr.plInformerSynced, cfgCtlr.fsInformerSynced); !ok { return fmt.Errorf("Never achieved initial sync") } klog.Info("Running API Priority and Fairness config worker") go wait.Until(cfgCtlr.runWorker, time.Second, stopCh) klog.Info("Running API Priority and Fairness periodic rebalancing process")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K 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) -
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)