- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for Queuing (0.36 sec)
-
pkg/apis/flowcontrol/validation/validation_test.go
LimitResponse: flowcontrol.LimitResponse{ Type: flowcontrol.LimitResponseTypeReject}, }, }, }, expectedErrors: field.ErrorList{}, }, { name: "forbid queuing details when not queuing", priorityLevelConfiguration: &flowcontrol.PriorityLevelConfiguration{ ObjectMeta: metav1.ObjectMeta{ Name: "system-foo", }, Spec: flowcontrol.PriorityLevelConfigurationSpec{
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
out.Type = flowcontrol.LimitResponseType(in.Type) out.Queuing = (*flowcontrol.QueuingConfiguration)(unsafe.Pointer(in.Queuing)) return nil } // Convert_v1beta3_LimitResponse_To_flowcontrol_LimitResponse is an autogenerated conversion function.
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
func autoConvert_v1_LimitResponse_To_flowcontrol_LimitResponse(in *v1.LimitResponse, out *flowcontrol.LimitResponse, s conversion.Scope) error { out.Type = flowcontrol.LimitResponseType(in.Type) out.Queuing = (*flowcontrol.QueuingConfiguration)(unsafe.Pointer(in.Queuing)) return nil } // Convert_v1_LimitResponse_To_flowcontrol_LimitResponse is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:41 UTC 2023 - 52.4K 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) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/transform/ArtifactTransformWithDependenciesIntegrationTest.groovy
// NOTE: filter out the dependency to trigger the problem, so that the main thread, which holds the project lock, does not see and isolate the second transform while // queuing the transforms for execution // The problem can potentially also be triggered by including many direct dependencies so that the queued transforms start to execute before the main thread sees the second transform
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 54.2K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
if err = controllerutil.MarkPodsNotReady(ctx, nc.kubeClient, nc.recorder, pods, node.Name); err != nil { utilruntime.HandleError(fmt.Errorf("unable to mark all pods NotReady on node %v: %v; queuing for retry", node.Name, err)) nc.nodesToRetry.Store(node.Name, struct{}{}) return } } } nc.nodesToRetry.Delete(node.Name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
Limited: &flowcontrol.LimitedPriorityLevelConfiguration{ NominalConcurrencyShares: ptr.To(concurrency), LimitResponse: flowcontrol.LimitResponse{ Type: responseType, Queuing: qcfg, }, }, }, } return []runtime.Object{fs, pl} } // gathers and checks the metrics. func checkForExpectedMetrics(t *testing.T, expectedMetrics []string) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
src/cmd/go/internal/modload/load.go
if modAddedBy[mod] == nil { modAddedBy[mod] = pkg } } return modAddedBy, nil } // pkg locates the *loadPkg for path, creating and queuing it for loading if // needed, and updates its state to reflect the given flags. // // The imports of the returned *loadPkg will be loaded asynchronously in the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 14:56:56 UTC 2024 - 84K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
o.podMaxInUnschedulablePodsDuration = duration } } // QueueingHintMapPerProfile is keyed with profile name, valued with queueing hint map registered for the profile. type QueueingHintMapPerProfile map[string]QueueingHintMap // QueueingHintMap is keyed with ClusterEvent, valued with queueing hint functions registered for the event. type QueueingHintMap map[framework.ClusterEvent][]*QueueingHintFunction
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0)