- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 291 for flowcontrolv1 (0.42 sec)
-
pkg/apis/flowcontrol/v1/defaults_test.go
Type: flowcontrolv1.PriorityLevelEnablementExempt, Exempt: &flowcontrolv1.ExemptPriorityLevelConfiguration{}, }, }, expected: &flowcontrolv1.PriorityLevelConfiguration{ Spec: flowcontrolv1.PriorityLevelConfigurationSpec{ Type: flowcontrolv1.PriorityLevelEnablementExempt, Exempt: &flowcontrolv1.ExemptPriorityLevelConfiguration{ NominalConcurrencyShares: ptr.To(int32(0)),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/registry/flowcontrol/ensurer/flowschema_test.go
} }) } } func TestFlowSchemaSpecChanged(t *testing.T) { fs1 := &flowcontrolv1.FlowSchema{ Spec: flowcontrolv1.FlowSchemaSpec{}, } fs2 := &flowcontrolv1.FlowSchema{ Spec: flowcontrolv1.FlowSchemaSpec{ MatchingPrecedence: 1, }, } fs1Defaulted := &flowcontrolv1.FlowSchema{ Spec: flowcontrolv1.FlowSchemaSpec{ MatchingPrecedence: flowcontrolapisv1.FlowSchemaDefaultMatchingPrecedence,
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/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 } func flowSchemaSpecEqual(expected, actual *flowcontrolv1.FlowSchema) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 1.6K bytes - Viewed (0) -
pkg/registry/flowcontrol/ensurer/prioritylevelconfiguration.go
return NewObjectOps[*flowcontrolv1.PriorityLevelConfiguration](client, lister, (*flowcontrolv1.PriorityLevelConfiguration).DeepCopy, plcReplaceSpec, plcSpecEqualish) } func plcReplaceSpec(into, from *flowcontrolv1.PriorityLevelConfiguration) *flowcontrolv1.PriorityLevelConfiguration { copy := into.DeepCopy()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 2K bytes - Viewed (0) -
pkg/registry/flowcontrol/ensurer/prioritylevelconfiguration_test.go
}) } } func TestPriorityLevelSpecChanged(t *testing.T) { pl1 := &flowcontrolv1.PriorityLevelConfiguration{ Spec: flowcontrolv1.PriorityLevelConfigurationSpec{ Type: flowcontrolv1.PriorityLevelEnablementLimited, Limited: &flowcontrolv1.LimitedPriorityLevelConfiguration{ LimitResponse: flowcontrolv1.LimitResponse{ Type: flowcontrolv1.LimitResponseTypeReject, }, }, }, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 14:34:53 UTC 2024 - 19.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/max_seats_test.go
limitations under the License. */ package flowcontrol import ( "testing" "time" flowcontrolv1 "k8s.io/api/flowcontrol/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" fqs "k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset" "k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/eventclock" "k8s.io/apiserver/pkg/util/flowcontrol/metrics" "k8s.io/client-go/informers"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 4.2K bytes - Viewed (0) -
pkg/registry/flowcontrol/prioritylevelconfiguration/strategy_test.go
v1ObjFn := func(v *int32) *flowcontrolv1.PriorityLevelConfiguration { return &flowcontrolv1.PriorityLevelConfiguration{ ObjectMeta: metav1.ObjectMeta{ Name: "foo", }, Spec: flowcontrolv1.PriorityLevelConfigurationSpec{ Type: flowcontrolv1.PriorityLevelEnablementLimited, Limited: &flowcontrolv1.LimitedPriorityLevelConfiguration{ NominalConcurrencyShares: v, LimitResponse: flowcontrolv1.LimitResponse{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 26 20:55:50 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/apis/flowcontrol/internalbootstrap/default-internal.go
limitations under the License. */ package internalbootstrap import ( flowcontrolv1 "k8s.io/api/flowcontrol/v1" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apiserver/pkg/apis/flowcontrol/bootstrap" "k8s.io/kubernetes/pkg/apis/flowcontrol" "k8s.io/kubernetes/pkg/apis/flowcontrol/install" ) // MandatoryFlowSchemas holds the untyped renditions of the mandatory
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 2.5K bytes - Viewed (0) -
pkg/apis/flowcontrol/install/install.go
"k8s.io/kubernetes/pkg/api/legacyscheme" "k8s.io/kubernetes/pkg/apis/flowcontrol" flowcontrolv1 "k8s.io/kubernetes/pkg/apis/flowcontrol/v1" flowcontrolv1beta1 "k8s.io/kubernetes/pkg/apis/flowcontrol/v1beta1" flowcontrolv1beta2 "k8s.io/kubernetes/pkg/apis/flowcontrol/v1beta2" flowcontrolv1beta3 "k8s.io/kubernetes/pkg/apis/flowcontrol/v1beta3" ) func init() { Install(legacyscheme.Scheme) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Dec 25 06:24:50 UTC 2023 - 1.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/format/formatting.go
} switch typed := sr.val.(type) { case *flowcontrol.FlowSchema, flowcontrol.FlowSchema, flowcontrol.FlowSchemaSpec, flowcontrol.FlowDistinguisherMethod, *flowcontrol.FlowDistinguisherMethod, *flowcontrol.PolicyRulesWithSubjects, flowcontrol.PolicyRulesWithSubjects, flowcontrol.Subject, flowcontrol.ResourcePolicyRule, flowcontrol.NonResourcePolicyRule, flowcontrol.FlowSchemaCondition,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 7.7K bytes - Viewed (0)