Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for testfunc (1.92 sec)

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