- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for priority_level (0.29 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go
uss.expectedInqueueReqs = uss.expectedInqueueReqs + fmt.Sprintf(` apiserver_flowcontrol_current_inqueue_requests{flow_schema=%q,priority_level=%q} 0%s`, fsName, uss.name, "\n") uss.expectedInqueueSeats = uss.expectedInqueueSeats + fmt.Sprintf(` apiserver_flowcontrol_current_inqueue_seats{flow_schema=%q,priority_level=%q} 0%s`, fsName, uss.name, "\n") for j := 0; j < uc.nThreads; j++ { ust := uniformScenarioThread{ uss: uss,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 58.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter.go
FlowcontrolClient flowcontrolclient.FlowcontrolV1Interface // ServerConcurrencyLimit for the controller to enforce ServerConcurrencyLimit int // GaugeVec for metrics about requests, broken down by phase and priority_level ReqsGaugeVec metrics.RatioedGaugeVec // RatioedGaugePairVec for metrics about seats occupied by all phases of execution ExecSeatsGaugeVec metrics.RatioedGaugeVec
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/metrics.go
func AddSeatConcurrencyInUse(priorityLevel, flowSchema string, delta int) { apiserverCurrentExecutingSeats.WithLabelValues(priorityLevel, flowSchema).Add(float64(delta)) apiserverRequestConcurrencyInUse.WithLabelValues(priorityLevel, flowSchema).Add(float64(delta)) } // AddReject increments the # of rejected requests for flow control func AddReject(ctx context.Context, priorityLevel, flowSchema, reason string) {
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/server/filters/priority-and-fairness_test.go
pollErr := wait.PollImmediate(100*time.Millisecond, 5*time.Second, func() (done bool, err error) { if err := gaugeValueMatch("apiserver_flowcontrol_nominal_limit_seats", map[string]string{"priority_level": plName}, plConcurrency); err != nil { t.Logf("polling retry - error: %s", err) return false, nil } return true, nil }) if pollErr != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.23.md
- **apiserver_flowcontrol_priority_level_seat_count_watermarks**: histograms of high and low watermarks of number of seats occupied by executing requests (both regular and final-delay phases included), broken down by priority_level.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 28 21:06:52 UTC 2023 - 424.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/apihelpers/helpers.go
func SetPriorityLevelConfigurationCondition(priorityLevel *flowcontrol.PriorityLevelConfiguration, newCondition flowcontrol.PriorityLevelConfigurationCondition) { existingCondition := GetPriorityLevelConfigurationConditionByType(priorityLevel, newCondition.Type) if existingCondition == nil { priorityLevel.Status.Conditions = append(priorityLevel.Status.Conditions, newCondition) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 3.4K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.22.md
- Added new metrics about API Priority and Fairness. Each one has a label `priority_level`. The last two also have a label `bound` taking values `min` and `max. - apiserver_flowcontrol_current_r: R(the time of the last change in state of the queues)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 13 12:43:45 UTC 2022 - 454.1K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1/types.go
const ( FlowSchemaMaxMatchingPrecedence int32 = 10000 ) // Constants for apiserver response headers. const ( ResponseHeaderMatchedPriorityLevelConfigurationUID = "X-Kubernetes-PF-PriorityLevel-UID" ResponseHeaderMatchedFlowSchemaUID = "X-Kubernetes-PF-FlowSchema-UID" ) const ( // AutoUpdateAnnotationKey is the name of an annotation that enables
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 31.1K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1beta2/types.go
const ( FlowSchemaMaxMatchingPrecedence int32 = 10000 ) // Constants for apiserver response headers. const ( ResponseHeaderMatchedPriorityLevelConfigurationUID = "X-Kubernetes-PF-PriorityLevel-UID" ResponseHeaderMatchedFlowSchemaUID = "X-Kubernetes-PF-FlowSchema-UID" ) const ( // AutoUpdateAnnotationKey is the name of an annotation that enables
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 17 09:27:57 UTC 2023 - 31.2K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1beta3/types.go
const ( FlowSchemaMaxMatchingPrecedence int32 = 10000 ) // Constants for apiserver response headers. const ( ResponseHeaderMatchedPriorityLevelConfigurationUID = "X-Kubernetes-PF-PriorityLevel-UID" ResponseHeaderMatchedFlowSchemaUID = "X-Kubernetes-PF-FlowSchema-UID" ) const ( // AutoUpdateAnnotationKey is the name of an annotation that enables
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:22:51 UTC 2023 - 31.9K bytes - Viewed (0)