- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for FlowSchemaSpec (0.25 sec)
-
pkg/apis/flowcontrol/validation/validation_test.go
"k8s.io/kubernetes/pkg/apis/flowcontrol" "k8s.io/kubernetes/pkg/apis/flowcontrol/internalbootstrap" "k8s.io/utils/pointer" ) func TestFlowSchemaValidation(t *testing.T) { badExempt := flowcontrol.FlowSchemaSpec{ MatchingPrecedence: 1, PriorityLevelConfiguration: flowcontrol.PriorityLevelConfigurationReference{ Name: flowcontrol.PriorityLevelConfigurationNameExempt, }, Rules: []flowcontrol.PolicyRulesWithSubjects{{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:22:51 UTC 2023 - 54.7K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1beta3/zz_generated.conversion.go
} if err := s.AddGeneratedConversionFunc((*v1beta3.FlowSchemaSpec)(nil), (*flowcontrol.FlowSchemaSpec)(nil), func(a, b interface{}, scope conversion.Scope) error { return Convert_v1beta3_FlowSchemaSpec_To_flowcontrol_FlowSchemaSpec(a.(*v1beta3.FlowSchemaSpec), b.(*flowcontrol.FlowSchemaSpec), scope) }); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:41 UTC 2023 - 53.1K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1/zz_generated.conversion.go
} if err := s.AddGeneratedConversionFunc((*v1.FlowSchemaSpec)(nil), (*flowcontrol.FlowSchemaSpec)(nil), func(a, b interface{}, scope conversion.Scope) error { return Convert_v1_FlowSchemaSpec_To_flowcontrol_FlowSchemaSpec(a.(*v1.FlowSchemaSpec), b.(*flowcontrol.FlowSchemaSpec), scope) }); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:41 UTC 2023 - 52.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/format/formatting.go
func FmtFlowSchemaSpec(fsSpec *flowcontrol.FlowSchemaSpec) string { var buf bytes.Buffer BufferFlowSchemaSpec(&buf, fsSpec) return buf.String() } // BufferFlowSchemaSpec writes a golang source expression for the // given value to the given buffer func BufferFlowSchemaSpec(buf *bytes.Buffer, fsSpec *flowcontrol.FlowSchemaSpec) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 7.7K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1/zz_generated.deepcopy.go
(*in)[i].DeepCopyInto(&(*out)[i]) } } return } // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FlowSchemaSpec. func (in *FlowSchemaSpec) DeepCopy() *FlowSchemaSpec { if in == nil { return nil } out := new(FlowSchemaSpec) in.DeepCopyInto(out) return out }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:41 UTC 2023 - 17.3K 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/apis/flowcontrol/v1/defaults.go
PriorityLevelConfigurationDefaultNominalConcurrencyShares int32 = 30 ) // SetDefaults_FlowSchema sets default values for flow schema func SetDefaults_FlowSchemaSpec(spec *v1.FlowSchemaSpec) { if spec.MatchingPrecedence == 0 { spec.MatchingPrecedence = FlowSchemaDefaultMatchingPrecedence } } func SetDefaults_ExemptPriorityLevelConfiguration(eplc *v1.ExemptPriorityLevelConfiguration) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1beta3/defaults.go
PriorityLevelConfigurationDefaultNominalConcurrencyShares int32 = 30 ) // SetDefaults_FlowSchema sets default values for flow schema func SetDefaults_FlowSchemaSpec(spec *v1beta3.FlowSchemaSpec) { if spec.MatchingPrecedence == 0 { spec.MatchingPrecedence = FlowSchemaDefaultMatchingPrecedence } } // SetDefaults_PriorityLevelConfiguration sets the default values for a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:22:51 UTC 2023 - 3K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1beta1/generated.pb.go
func (m *FlowSchemaSpec) Reset() { *m = FlowSchemaSpec{} } func (*FlowSchemaSpec) ProtoMessage() {} func (*FlowSchemaSpec) Descriptor() ([]byte, []int) { return fileDescriptor_3a5cb22a034fcb2a, []int{5} } func (m *FlowSchemaSpec) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *FlowSchemaSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 142K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter_test.go
username := "test-user" fsName := "test-fs" lendable := int32(0) borrowingLimit := int32(0) fsObj = &flowcontrol.FlowSchema{ ObjectMeta: metav1.ObjectMeta{ Name: fsName, }, Spec: flowcontrol.FlowSchemaSpec{ MatchingPrecedence: 100, PriorityLevelConfiguration: flowcontrol.PriorityLevelConfigurationReference{ Name: plName, }, DistinguisherMethod: &flowcontrol.FlowDistinguisherMethod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 5.6K bytes - Viewed (0)