Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 76 for fh (0.02 sec)

  1. pkg/scheduler/framework/plugins/noderesources/balanced_allocation_test.go

    			_, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    			fh, _ := runtime.NewFramework(ctx, nil, nil, runtime.WithSnapshotSharedLister(snapshot))
    			p, _ := NewBalancedAllocation(ctx, &test.args, fh, feature.Features{})
    			state := framework.NewCycleState()
    			for i := range test.nodes {
    				if test.runPreScore {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 15.9K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions_test.go

    	pluginFactory := func(ctx context.Context, plArgs runtime.Object, fh framework.Handle) (framework.Plugin, error) {
    		return New(ctx, plArgs, fh, feature.Features{})
    	}
    	snapshot := cache.NewSnapshot(pods, nodes)
    
    	objects := make([]runtime.Object, 0, len(pvcs))
    	for _, pvc := range pvcs {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 17:40:39 UTC 2023
    - 17.3K bytes
    - Viewed (0)
  3. src/image/decode_example_test.go

    jSgyxfJt6EgdDzWTdeLIZGO7zHI/hVajGmWWP+PWL8qwlAIURrhpMAHHJA71pRcZrToZzcoEuo6heakA
    GHk245CZ6/X1qPTLq40q+W5t2QybSpDAkEEc55/zilk5k2r91eKhLDzWz2rpsczbbuemeD76fUNG865I
    MiysmQMZAAwa3a5j4ftu0ByP+fh/5CulkLLG7INzhSVHqe1Fh3uOoqn9qQQxyhndmHIxwOmSR2xQ13KD
    KoiBZOV9JBnt707MVy5RWdNdy7wRGf3bfMinnO1jg+vY03WXLaJO3mhQ20b0zwpYf0qlG7S7icrJs08U
    VwumgC+YiQyeVtZH567hzj8aSL949oGhE/2v5pJCDkksQwBHC4/+vXQ8LZ2uYxxCavY7us/xCcaBfn0h
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 29 03:16:17 UTC 2018
    - 7.5K bytes
    - Viewed (0)
  4. src/net/http/request_test.go

    		}
    	}
    }
    
    func testMissingFile(t *testing.T, req *Request) {
    	f, fh, err := req.FormFile("missing")
    	if f != nil {
    		t.Errorf("FormFile file = %v, want nil", f)
    	}
    	if fh != nil {
    		t.Errorf("FormFile file header = %v, want nil", fh)
    	}
    	if err != ErrMissingFile {
    		t.Errorf("FormFile err = %q, want ErrMissingFile", err)
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 18:42:34 UTC 2024
    - 44K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/runtime/framework_test.go

    	r := make(Registry)
    	r.Register(preFilterPluginName,
    		func(_ context.Context, _ runtime.Object, fh framework.Handle) (framework.Plugin, error) {
    			return preFilter1, nil
    		})
    	r.Register(preFilterWithExtensionsPluginName,
    		func(_ context.Context, _ runtime.Object, fh framework.Handle) (framework.Plugin, error) {
    			return preFilter2, nil
    		})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
  6. pkg/kube/kclient/client.go

    	defer n.handlerMu.Unlock()
    	for _, c := range n.registeredHandlers {
    		_ = n.informer.RemoveEventHandler(c.registration)
    	}
    }
    
    func (n *informerClient[T]) AddEventHandler(h cache.ResourceEventHandler) {
    	fh := cache.FilteringResourceEventHandler{
    		FilterFunc: func(obj interface{}) bool {
    			if n.filter == nil {
    				return true
    			}
    			return n.filter(obj)
    		},
    		Handler: h,
    	}
    	n.handlerMu.Lock()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 07:14:28 UTC 2024
    - 13K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    				t.Fatal(err)
    			}
    
    			pl := &DefaultPreemption{
    				fh:        fwk,
    				podLister: informerFactory.Core().V1().Pods().Lister(),
    				pdbLister: getPDBLister(informerFactory),
    				args:      *getDefaultDefaultPreemptionArgs(),
    			}
    			pe := preemption.Evaluator{
    				PluginName: names.DefaultPreemption,
    				Handler:    pl.fh,
    				PodLister:  pl.podLister,
    				PdbLister:  pl.pdbLister,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration_test.go

    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    
    			state := framework.NewCycleState()
    			snapshot := cache.NewSnapshot(nil, test.nodes)
    			fh, _ := runtime.NewFramework(ctx, nil, nil, runtime.WithSnapshotSharedLister(snapshot))
    
    			p, err := New(ctx, nil, fh, feature.Features{})
    			if err != nil {
    				t.Fatalf("creating plugin: %v", err)
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/noderesources/most_allocated_test.go

    			snapshot := cache.NewSnapshot(test.existingPods, test.nodes)
    			fh, _ := runtime.NewFramework(ctx, nil, nil, runtime.WithSnapshotSharedLister(snapshot))
    
    			p, err := NewFit(ctx,
    				&config.NodeResourcesFitArgs{
    					ScoringStrategy: &config.ScoringStrategy{
    						Type:      config.MostAllocated,
    						Resources: test.resources,
    					},
    				}, fh, plfeature.Features{})
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 16K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/noderesources/least_allocated_test.go

    			snapshot := cache.NewSnapshot(test.existingPods, test.nodes)
    			fh, _ := runtime.NewFramework(ctx, nil, nil, runtime.WithSnapshotSharedLister(snapshot))
    
    			p, err := NewFit(
    				ctx,
    				&config.NodeResourcesFitArgs{
    					ScoringStrategy: &config.ScoringStrategy{
    						Type:      config.LeastAllocated,
    						Resources: test.resources,
    					},
    				}, fh, plfeature.Features{})
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 18.8K bytes
    - Viewed (0)
Back to top