Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 74 for queueLengthLimit (0.24 sec)

  1. pkg/printers/internalversion/printers.go

    	queues := interface{}("<none>")
    	handSize := interface{}("<none>")
    	queueLengthLimit := interface{}("<none>")
    	if obj.Spec.Limited != nil {
    		ncs = obj.Spec.Limited.NominalConcurrencyShares
    		if qc := obj.Spec.Limited.LimitResponse.Queuing; qc != nil {
    			queues = qc.Queues
    			handSize = qc.HandSize
    			queueLengthLimit = qc.QueueLengthLimit
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/api/flowcontrol/v1beta2/generated.pb.go

    				return fmt.Errorf("proto: wrong wireType = %d for field QueueLengthLimit", wireType)
    			}
    			m.QueueLengthLimit = 0
    			for shift := uint(0); ; shift += 7 {
    				if shift >= 64 {
    					return ErrIntOverflowGenerated
    				}
    				if iNdEx >= l {
    					return io.ErrUnexpectedEOF
    				}
    				b := dAtA[iNdEx]
    				iNdEx++
    				m.QueueLengthLimit |= int32(b&0x7F) << shift
    				if b < 0x80 {
    					break
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 142K bytes
    - Viewed (0)
  3. staging/src/k8s.io/api/flowcontrol/v1beta1/generated.pb.go

    				return fmt.Errorf("proto: wrong wireType = %d for field QueueLengthLimit", wireType)
    			}
    			m.QueueLengthLimit = 0
    			for shift := uint(0); ; shift += 7 {
    				if shift >= 64 {
    					return ErrIntOverflowGenerated
    				}
    				if iNdEx >= l {
    					return io.ErrUnexpectedEOF
    				}
    				b := dAtA[iNdEx]
    				iNdEx++
    				m.QueueLengthLimit |= int32(b&0x7F) << shift
    				if b < 0x80 {
    					break
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 142K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/flowcontrol/v1beta3/generated.pb.go

    				return fmt.Errorf("proto: wrong wireType = %d for field QueueLengthLimit", wireType)
    			}
    			m.QueueLengthLimit = 0
    			for shift := uint(0); ; shift += 7 {
    				if shift >= 64 {
    					return ErrIntOverflowGenerated
    				}
    				if iNdEx >= l {
    					return io.ErrUnexpectedEOF
    				}
    				b := dAtA[iNdEx]
    				iNdEx++
    				m.QueueLengthLimit |= int32(b&0x7F) << shift
    				if b < 0x80 {
    					break
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 141.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/api/flowcontrol/v1/generated.pb.go

    				return fmt.Errorf("proto: wrong wireType = %d for field QueueLengthLimit", wireType)
    			}
    			m.QueueLengthLimit = 0
    			for shift := uint(0); ; shift += 7 {
    				if shift >= 64 {
    					return ErrIntOverflowGenerated
    				}
    				if iNdEx >= l {
    					return io.ErrUnexpectedEOF
    				}
    				b := dAtA[iNdEx]
    				iNdEx++
    				m.QueueLengthLimit |= int32(b&0x7F) << shift
    				if b < 0x80 {
    					break
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 141.8K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/gen_test.go

    		hs := rng.Int31n(5) + 1
    		plc.Spec.Limited.LimitResponse.Queuing = &flowcontrol.QueuingConfiguration{
    			Queues:           hs + rng.Int31n(20),
    			HandSize:         hs,
    			QueueLengthLimit: 5}
    	}
    	labelVals := []string{"test"}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 24.8K bytes
    - Viewed (0)
  7. pkg/printers/internalversion/printers_test.go

    							Queuing: &flowcontrol.QueuingConfiguration{
    								Queues:           8,
    								HandSize:         3,
    								QueueLengthLimit: 4,
    							},
    						},
    					},
    				},
    			},
    			// Columns: Name, Type, NominalConcurrencyShares, Queues, HandSize, QueueLengthLimit, Age
    			expected: []metav1.TableRow{{Cells: []interface{}{"queued", "Limited", int32(42), int32(8), int32(3), int32(4), "0s"}}},
    		},
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 218.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go

    		qcfg         *flowcontrol.QueuingConfiguration
    	)
    	if queueLength > 0 {
    		responseType = flowcontrol.LimitResponseTypeQueue
    		qcfg = &flowcontrol.QueuingConfiguration{
    			Queues:           1,
    			QueueLengthLimit: queueLength,
    			HandSize:         1,
    		}
    	}
    	pl := &flowcontrol.PriorityLevelConfiguration{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: plName,
    			UID:  types.UID(plName),
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 52.6K bytes
    - Viewed (0)
  9. api/openapi-spec/v3/apis__flowcontrol.apiserver.k8s.io__v1beta3_openapi.json

                "format": "int32",
                "type": "integer"
              },
              "queueLengthLimit": {
                "default": 0,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 232.7K bytes
    - Viewed (0)
  10. api/openapi-spec/v3/apis__flowcontrol.apiserver.k8s.io__v1_openapi.json

                "format": "int32",
                "type": "integer"
              },
              "queueLengthLimit": {
                "default": 0,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 231.7K bytes
    - Viewed (0)
Back to top