- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 125 for flow_schema (0.18 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{
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/metrics/metrics.go
apiserverCurrentInqueueSeats.WithLabelValues(priorityLevel, flowSchema).Add(float64(delta)) } // AddRequestsExecuting adds the given delta to the gauge of executing requests of the given flowSchema and priorityLevel func AddRequestsExecuting(ctx context.Context, priorityLevel, flowSchema string, delta int) { apiserverCurrentExecutingRequests.WithLabelValues(priorityLevel, flowSchema).Add(float64(delta)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 24 19:40:05 UTC 2023 - 25.6K bytes - Viewed (0) -
pkg/registry/flowcontrol/ensurer/flowschema.go
return NewObjectOps[*flowcontrolv1.FlowSchema](client, cache, (*flowcontrolv1.FlowSchema).DeepCopy, flowSchemaReplaceSpec, flowSchemaSpecEqual) } func flowSchemaReplaceSpec(into, from *flowcontrolv1.FlowSchema) *flowcontrolv1.FlowSchema { copy := into.DeepCopy() copy.Spec = *from.Spec.DeepCopy() return copy }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 1.6K bytes - Viewed (0) -
api/discovery/apis__flowcontrol.apiserver.k8s.io__v1beta3.json
{ "apiVersion": "v1", "groupVersion": "flowcontrol.apiserver.k8s.io/v1beta3", "kind": "APIResourceList", "resources": [ { "kind": "FlowSchema", "name": "flowschemas", "namespaced": false, "singularName": "flowschema", "storageVersionHash": "GJVAJZSZBIw=", "verbs": [ "create", "delete", "deletecollection", "get", "list", "patch",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Dec 25 06:24:50 UTC 2023 - 1.3K bytes - Viewed (0) -
api/discovery/apis__flowcontrol.apiserver.k8s.io__v1.json
{ "apiVersion": "v1", "groupVersion": "flowcontrol.apiserver.k8s.io/v1", "kind": "APIResourceList", "resources": [ { "kind": "FlowSchema", "name": "flowschemas", "namespaced": false, "singularName": "flowschema", "storageVersionHash": "GJVAJZSZBIw=", "verbs": [ "create", "delete", "deletecollection", "get", "list", "patch",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Dec 25 06:24:50 UTC 2023 - 1.3K bytes - Viewed (0) -
pkg/registry/flowcontrol/flowschema/storage/storage.go
NewListFunc: func() runtime.Object { return &flowcontrol.FlowSchemaList{} }, DefaultQualifiedResource: flowcontrol.Resource("flowschemas"), SingularQualifiedResource: flowcontrol.Resource("flowschema"), CreateStrategy: flowschema.Strategy, UpdateStrategy: flowschema.Strategy, DeleteStrategy: flowschema.Strategy,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 13 15:11:04 UTC 2023 - 4.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
// and nothing more needs to be done here. klog.V(5).Infof("%s at %s: attempted update of concurrently deleted FlowSchema %s; nothing more needs to be done", cfgCtlr.name, cfgCtlr.clock.Now().Format(timeFmt), fsu.flowSchema.Name) } else { errs = append(errs, fmt.Errorf("failed to set a status.condition for FlowSchema %s: %w", fsu.flowSchema.Name, err)) } } } cfgCtlr.addUpdateResult(currResult)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
pkg/registry/flowcontrol/ensurer/flowschema_test.go
strategy func() EnsureStrategy[*flowcontrolv1.FlowSchema] current *flowcontrolv1.FlowSchema bootstrap *flowcontrolv1.FlowSchema expected *flowcontrolv1.FlowSchema }{ // for suggested configurations { name: "suggested flow schema does not exist - the object should always be re-created", strategy: NewSuggestedEnsureStrategy[*flowcontrolv1.FlowSchema], bootstrap: newFlowSchema("fs1", "pl1", 100).Object(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 15.2K bytes - Viewed (0) -
pkg/registry/flowcontrol/rest/storage_flowcontrol.go
return err } fsOps := ensurer.NewFlowSchemaOps(clientset.FlowSchemas(), fsLister) return ensurer.EnsureConfigurations(ctx, fsOps, flowcontrolbootstrap.SuggestedFlowSchemas, ensurer.NewSuggestedEnsureStrategy[*flowcontrolv1.FlowSchema]()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 12.3K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/HEAD/flowcontrol.apiserver.k8s.io.v1beta1.FlowSchema.yaml
apiVersion: flowcontrol.apiserver.k8s.io/v1beta1 kind: FlowSchema metadata: annotations: annotationsKey: annotationsValue creationTimestamp: "2008-01-01T01:01:01Z" deletionGracePeriodSeconds: 10 deletionTimestamp: "2009-01-01T01:01:01Z" finalizers: - finalizersValue generateName: generateNameValue generation: 7 labels: labelsKey: labelsValue managedFields: - apiVersion: apiVersionValue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 06 21:25:20 UTC 2022 - 1.6K bytes - Viewed (0)