- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 135 for Queuing (0.27 sec)
-
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) -
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) -
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) -
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) -
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) -
staging/src/k8s.io/api/flowcontrol/v1beta2/generated.pb.go
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/api/flowcontrol/v1beta1/generated.pb.go
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/api/flowcontrol/v1beta3/generated.pb.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 141.9K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1/generated.pb.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 141.8K bytes - Viewed (0) -
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)