- Sort Score
- Result 10 results
- Languages All
Results 11 - 16 of 16 for testfunc (1.92 sec)
-
pkg/scheduler/framework/interface.go
type PreEnqueuePlugin interface { Plugin // PreEnqueue is called prior to adding Pods to activeQ. PreEnqueue(ctx context.Context, p *v1.Pod) *Status } // LessFunc is the function to sort pod info type LessFunc func(podInfo1, podInfo2 *QueuedPodInfo) bool // QueueSortPlugin is an interface that must be implemented by "QueueSort" plugins.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
src/cmd/cover/cover.go
f.preFunc(n, fname) if pkgconfig.Granularity == "perfunc" { walkBody = false } } if walkBody { ast.Walk(f, n.Body) } if *pkgcfg != "" { flit := false f.postFunc(n, fname, flit, n.Body) } return nil case *ast.FuncLit: // For function literals enclosed in functions, just glom the // code for the literal in with the enclosing function (for now).
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 34.5K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/filters_test.go
delete(expected, k) if _, ok := unexpected[k]; ok { t.Errorf("expected %s to be filtered out", k) } } if len(expected) > 0 { t.Errorf("did not include %v", expected) } } func TestRun(t *testing.T) { // source svc/cluster -> dest services -> number of subtests (should == num clusters) framework.NewTest(t).Run(func(t framework.TestContext) { tests := map[string]struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 13.1K bytes - Viewed (0) -
cmd/kube-proxy/app/server_linux.go
ctx, cancelFunc := context.WithTimeout(ctx, timeoutForNodePodCIDR) defer cancelFunc() fieldSelector := fields.OneTermEqualSelector("metadata.name", nodeName).String() lw := &cache.ListWatch{ ListFunc: func(options metav1.ListOptions) (object runtime.Object, e error) { options.FieldSelector = fieldSelector return client.CoreV1().Nodes().List(ctx, options) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 18.1K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
Close() // Run starts the goroutines managing the queue. Run(logger klog.Logger) } // NewSchedulingQueue initializes a priority queue as a new scheduling queue. func NewSchedulingQueue( lessFn framework.LessFunc, informerFactory informers.SharedInformerFactory, opts ...Option) SchedulingQueue { return NewPriorityQueue(lessFn, informerFactory, opts...) } // NominatedNodeName returns nominated node name of a Pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
t.Errorf("Expected medPriorityPodInfo and unschedulablePodInfo to be still present in nomindatePods: %v", q.nominator.nominatedPods["node1"]) } } func newDefaultQueueSort() framework.LessFunc { sort := &queuesort.PrioritySort{} return sort.Less } func TestPriorityQueue_AddWithReversePriorityLessFunc(t *testing.T) { objs := []runtime.Object{medPriorityPodInfo.Pod, highPriorityPodInfo.Pod}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0)