Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 135 for Queuing (0.27 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/borrowing_test.go

    							BorrowingLimitPercent:    &testCase.constraints[flow].borrowing,
    							LimitResponse: flowcontrol.LimitResponse{
    								Type: flowcontrol.LimitResponseTypeQueue,
    								Queuing: &flowcontrol.QueuingConfiguration{
    									Queues:           10,
    									HandSize:         2,
    									QueueLengthLimit: 10,
    								},
    							},
    						},
    					},
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 9K bytes
    - Viewed (0)
  2. pkg/apis/flowcontrol/v1beta1/zz_generated.conversion.go

    	out.Type = flowcontrol.LimitResponseType(in.Type)
    	out.Queuing = (*flowcontrol.QueuingConfiguration)(unsafe.Pointer(in.Queuing))
    	return nil
    }
    
    // Convert_v1beta1_LimitResponse_To_flowcontrol_LimitResponse is an autogenerated conversion function.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 14 01:00:06 UTC 2023
    - 53.5K bytes
    - Viewed (0)
  3. pkg/apis/flowcontrol/v1beta2/zz_generated.conversion.go

    	out.Type = flowcontrol.LimitResponseType(in.Type)
    	out.Queuing = (*flowcontrol.QueuingConfiguration)(unsafe.Pointer(in.Queuing))
    	return nil
    }
    
    // Convert_v1beta2_LimitResponse_To_flowcontrol_LimitResponse is an autogenerated conversion function.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 14 01:00:06 UTC 2023
    - 53.5K bytes
    - Viewed (0)
  4. pkg/controller/endpointslice/endpointslice_controller.go

    	// rate-limiter in use (1s*2^(numRetries-1)) the following numbers represent
    	// the sequence of delays between successive queuings of a service.
    	//
    	// 1s, 2s, 4s, 8s, 16s, 32s, 64s, 128s, 256s, 512s, 1000s (max)
    	maxRetries = 15
    
    	// endpointSliceChangeMinSyncDelay indicates the minimum delay before
    	// queuing a syncService call after an EndpointSlice changes. If
    	// endpointUpdatesBatchPeriod is greater than this value, it will be used
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  5. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/ComponentState.java

            if (resolveState != null) {
                return resolveState.getId();
            }
            return componentIdentifier;
        }
    
        /**
         * Restarts all incoming edges for this component, queuing them up for processing.
         */
        public void restartIncomingEdges(ComponentState selected) {
            for (NodeState node : nodes) {
                node.restart(selected);
            }
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 02:21:08 UTC 2024
    - 17K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/flowcontrol/v1beta2/generated.pb.go

    			if postIndex < 0 {
    				return ErrInvalidLengthGenerated
    			}
    			if postIndex > l {
    				return io.ErrUnexpectedEOF
    			}
    			if m.Queuing == nil {
    				m.Queuing = &QueuingConfiguration{}
    			}
    			if err := m.Queuing.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
    				return err
    			}
    			iNdEx = postIndex
    		default:
    			iNdEx = preIndex
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 142K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/flowcontrol/v1beta1/generated.pb.go

    			if postIndex < 0 {
    				return ErrInvalidLengthGenerated
    			}
    			if postIndex > l {
    				return io.ErrUnexpectedEOF
    			}
    			if m.Queuing == nil {
    				m.Queuing = &QueuingConfiguration{}
    			}
    			if err := m.Queuing.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
    				return err
    			}
    			iNdEx = postIndex
    		default:
    			iNdEx = preIndex
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 142K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/flowcontrol/v1beta3/generated.pb.go

    			if postIndex < 0 {
    				return ErrInvalidLengthGenerated
    			}
    			if postIndex > l {
    				return io.ErrUnexpectedEOF
    			}
    			if m.Queuing == nil {
    				m.Queuing = &QueuingConfiguration{}
    			}
    			if err := m.Queuing.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
    				return err
    			}
    			iNdEx = postIndex
    		default:
    			iNdEx = preIndex
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 141.9K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/flowcontrol/v1/generated.pb.go

    			if postIndex < 0 {
    				return ErrInvalidLengthGenerated
    			}
    			if postIndex > l {
    				return io.ErrUnexpectedEOF
    			}
    			if m.Queuing == nil {
    				m.Queuing = &QueuingConfiguration{}
    			}
    			if err := m.Queuing.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
    				return err
    			}
    			iNdEx = postIndex
    		default:
    			iNdEx = preIndex
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 141.8K bytes
    - Viewed (0)
  10. src/time/sleep_test.go

    	delayadj := adjustDelay(t, delay)
    	duration := Since(start)
    	if duration < delayadj {
    		t.Fatalf("Sleep(%s) slept for only %s", delay, duration)
    	}
    }
    
    // Test the basic function calling behavior. Correct queuing
    // behavior is tested elsewhere, since After and AfterFunc share
    // the same code.
    func TestAfterFunc(t *testing.T) {
    	i := 10
    	c := make(chan bool)
    	var f func()
    	f = func() {
    		i--
    		if i >= 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 22 16:33:57 UTC 2024
    - 22.5K bytes
    - Viewed (0)
Back to top