Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for Queuing (0.36 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top