- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 301 for flowcontrolv1 (0.31 sec)
-
staging/src/k8s.io/apiserver/pkg/apis/flowcontrol/bootstrap/default_test.go
lendablePercentexpected: 0, }, } bootstrapPLs := func() map[string]*flowcontrol.PriorityLevelConfiguration { list := make([]*flowcontrol.PriorityLevelConfiguration, 0) list = append(list, MandatoryPriorityLevelConfigurations...) list = append(list, SuggestedPriorityLevelConfigurations...) m := map[string]*flowcontrol.PriorityLevelConfiguration{} for i := range list { m[list[i].Name] = list[i] }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1/doc.go
limitations under the License. */ // +k8s:conversion-gen=k8s.io/kubernetes/pkg/apis/flowcontrol // +k8s:conversion-gen-external-types=k8s.io/api/flowcontrol/v1 // +k8s:defaulter-gen=TypeMeta // +k8s:defaulter-gen-input=k8s.io/api/flowcontrol/v1 // +groupName=flowcontrol.apiserver.k8s.io
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 11:48:22 UTC 2023 - 892 bytes - Viewed (0) -
pkg/apis/flowcontrol/v1beta3/doc.go
limitations under the License. */ // +k8s:conversion-gen=k8s.io/kubernetes/pkg/apis/flowcontrol // +k8s:conversion-gen-external-types=k8s.io/api/flowcontrol/v1beta3 // +k8s:defaulter-gen=TypeMeta // +k8s:defaulter-gen-input=k8s.io/api/flowcontrol/v1beta3 // +groupName=flowcontrol.apiserver.k8s.io
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 21 22:54:19 UTC 2022 - 912 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter.go
fcrequest "k8s.io/apiserver/pkg/util/flowcontrol/request" kubeinformers "k8s.io/client-go/informers" "k8s.io/klog/v2" "k8s.io/utils/clock" flowcontrol "k8s.io/api/flowcontrol/v1" flowcontrolclient "k8s.io/client-go/kubernetes/typed/flowcontrol/v1" ) // ConfigConsumerAsFieldManager is how the config consuminng // controller appears in an ObjectMeta ManagedFieldsEntry.Manager
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/rule.go
} func matchesASubject(user user.Info, subjects []flowcontrol.Subject) bool { for _, subject := range subjects { if matchesSubject(user, subject) { return true } } return false } func matchesSubject(user user.Info, subject flowcontrol.Subject) bool { switch subject.Kind { case flowcontrol.SubjectKindUser: return subject.User != nil && (subject.User.Name == flowcontrol.NameAll || subject.User.Name == user.GetName())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/registry/flowcontrol/prioritylevelconfiguration/strategy.go
fields := map[fieldpath.APIVersion]*fieldpath.Set{ "flowcontrol.apiserver.k8s.io/v1beta1": fieldpath.NewSet( fieldpath.MakePathOrDie("status"), ), "flowcontrol.apiserver.k8s.io/v1beta2": fieldpath.NewSet( fieldpath.MakePathOrDie("status"), ), "flowcontrol.apiserver.k8s.io/v1beta3": fieldpath.NewSet( fieldpath.MakePathOrDie("status"), ), "flowcontrol.apiserver.k8s.io/v1": fieldpath.NewSet(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 26 20:55:50 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/apis/flowcontrol/validation/validation.go
string(flowcontrol.SubjectKindServiceAccount), string(flowcontrol.SubjectKindGroup), string(flowcontrol.SubjectKindUser), ) var supportedPriorityLevelEnablement = sets.NewString( string(flowcontrol.PriorityLevelEnablementExempt), string(flowcontrol.PriorityLevelEnablementLimited), ) var supportedLimitResponseType = sets.NewString( string(flowcontrol.LimitResponseTypeQueue),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:22:51 UTC 2023 - 26.7K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1beta3/conversion_test.go
} } outObjFn := func(shares int32, annotations map[string]string) *flowcontrol.PriorityLevelConfiguration { return &flowcontrol.PriorityLevelConfiguration{ ObjectMeta: metav1.ObjectMeta{ Annotations: annotations, }, Spec: flowcontrol.PriorityLevelConfigurationSpec{ Type: flowcontrol.PriorityLevelEnablementLimited, Limited: &flowcontrol.LimitedPriorityLevelConfiguration{ NominalConcurrencyShares: shares,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:22:51 UTC 2023 - 7.6K bytes - Viewed (0) -
pkg/registry/flowcontrol/flowschema/storage/storage.go
store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &flowcontrol.FlowSchema{} }, NewListFunc: func() runtime.Object { return &flowcontrol.FlowSchemaList{} }, DefaultQualifiedResource: flowcontrol.Resource("flowschemas"), SingularQualifiedResource: flowcontrol.Resource("flowschema"), CreateStrategy: flowschema.Strategy, UpdateStrategy: 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) -
pkg/apis/flowcontrol/v1beta2/conversion_test.go
Type: v1beta2.LimitResponseTypeReject, }, }, expected: &flowcontrol.LimitedPriorityLevelConfiguration{ NominalConcurrencyShares: 100, LimitResponse: flowcontrol.LimitResponse{ Type: flowcontrol.LimitResponseTypeReject, }, }, }, } for _, test := range tests { t.Run(test.name, func(t *testing.T) { out := &flowcontrol.LimitedPriorityLevelConfiguration{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 26 19:34:10 UTC 2022 - 3K bytes - Viewed (0)